Package | Description |
---|---|
ds.granules.communication.direct | |
ds.granules.exchange |
This package contains classes related to processing exchanges.
|
ds.granules.operation |
This package encapsulates functionality related to application instances that will be deployed on the cloud.
|
ds.granules.scheduler |
This package contains functionality related to scheduling the application instances.
|
ds.granules.streaming.core |
Modifier and Type | Method and Description |
---|---|
ProgressTracker |
JobDeployer.deployOperations(Operation[] operations) |
Modifier and Type | Method and Description |
---|---|
Operation |
DeploymentMessage.getOperation() |
Modifier and Type | Method and Description |
---|---|
DeploymentMessage |
ExchangeFactory.createDepoymentRequest(String jobIdentifier,
Operation operation,
String respondTo)
Creates a deployment request based on the specified parameters.
|
Constructor and Description |
---|
DeploymentMessage(String jobIdentifier,
Operation operation,
String respondTo)
Creates a deployment message based on the specified parameters.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Map
This interface corresponds to the Map role in a Map-Reduce operation.
|
interface |
MapReduce
This is an interface which encapsulates functionality that is common to both
the
Map and Reduce roles that are associated with
the applications. |
interface |
Reduce
This interface corresponds to the Reduce role in a Map-Reduce
operation.
|
Modifier and Type | Class and Description |
---|---|
class |
MapReduceBase
This is the base class which will serve as the base for implementations of
the
Map and Reduce interface. |
class |
OperationBase
This is an implementation of the
Operation and
OperationConfiguration interfaces. |
Modifier and Type | Method and Description |
---|---|
Operation |
Operation.OperationType.unmarshall(ds.funnel.data.format.FormatReader mFormat) |
Modifier and Type | Method and Description |
---|---|
ProgressTracker |
JobSubmission.deploy(Operation[] operations,
int numOfResources,
String jobIdentifier,
JobLifecycleObserver jobLifecycleObserver) |
ProgressTracker |
InstanceDeployer.deployOperations(Operation[] operations)
This method deploys a set of operations on a specified number of
resources.
|
ProgressTracker |
Deployer.deployOperations(Operation[] operations) |
ProgressTracker |
InstanceDeployer.deployOperations(Operation[] operations,
int numOfResources,
String jobIdentifier)
This method deploys a set of operations on a specified number of
resources.
|
ProgressTracker |
InstanceDeployer.deployOperations(Operation[] operations,
String jobIdentifier)
This method deploys a set of operations on the set of available
resources.
|
ProgressTracker |
JobSubmission.submit(Operation operation,
JobLifecycleObserver jobLifecycleObserver)
Submit the given operation for execution.
|
ProgressTracker |
JobSubmission.submit(Operation operation,
String resourceDeploymentStream,
JobLifecycleObserver jobLifecycleObserver)
Submit the given operation for execution.
|
ProgressTracker |
JobSubmission.submit(Operation operation,
String resourceDeploymentStream,
String jobIdentifier,
JobLifecycleObserver jobLifecycleObserver)
This method allows one to group a set of related tasks together in a Job.
|
Modifier and Type | Method and Description |
---|---|
Operation |
ExecutableTask.getOperation()
Retrieve the operation that will be executed by this task
|
Modifier and Type | Method and Description |
---|---|
void |
TaskManagement.manageExecution(String taskIdentifier,
Operation operation)
Manage the execution of the given operation
|
Constructor and Description |
---|
ExecutableTask(String taskIdentifier,
Operation operation,
TaskLifecycleObserver taskLifetimeObserver) |
Modifier and Type | Class and Description |
---|---|
class |
StreamBase
This class is the base class for
StreamSource and StreamProcessor . |
class |
StreamProcessor
Any stream processing element should extend this abstract class.
|
class |
StreamSource
This class should be extended to implement a stream source.
|
Copyright © 2015. All rights reserved.