Uses of Interface
ds.granules.operation.Operation

Packages that use Operation

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

Uses of Operation in ds.granules.communication.direct

Methods in ds.granules.communication.direct with parameters of type Operation

Modifier and Type	Method and Description
ProgressTracker	JobDeployer.deployOperations(Operation[] operations)

Uses of Operation in ds.granules.exchange

Methods in ds.granules.exchange that return Operation

Modifier and Type	Method and Description
Operation	DeploymentMessage.getOperation()

Methods in ds.granules.exchange with parameters of type Operation

Modifier and Type	Method and Description
DeploymentMessage	ExchangeFactory.createDepoymentRequest(String jobIdentifier, Operation operation, String respondTo) Creates a deployment request based on the specified parameters.

Constructors in ds.granules.exchange with parameters of type Operation

Constructor and Description
DeploymentMessage(String jobIdentifier, Operation operation, String respondTo) Creates a deployment message based on the specified parameters.

Uses of Operation in ds.granules.operation

Subinterfaces of Operation in ds.granules.operation

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.

Classes in ds.granules.operation that implement 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.

Methods in ds.granules.operation that return Operation

Modifier and Type	Method and Description
Operation	Operation.OperationType.unmarshall(ds.funnel.data.format.FormatReader mFormat)

Methods in ds.granules.operation with parameters of type Operation

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.

Uses of Operation in ds.granules.scheduler

Methods in ds.granules.scheduler that return Operation

Modifier and Type	Method and Description
Operation	ExecutableTask.getOperation() Retrieve the operation that will be executed by this task

Methods in ds.granules.scheduler with parameters of type Operation

Modifier and Type	Method and Description
void	TaskManagement.manageExecution(String taskIdentifier, Operation operation) Manage the execution of the given operation

Constructors in ds.granules.scheduler with parameters of type Operation

Constructor and Description
ExecutableTask(String taskIdentifier, Operation operation, TaskLifecycleObserver taskLifetimeObserver)

Uses of Operation in ds.granules.streaming.core

Classes in ds.granules.streaming.core that implement Operation

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.