Package | Description |
---|---|
ds.granules | |
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 |
Class and Description |
---|
JobSubmission
This class manages the submission, tracking and cancellation of Jobs and
their constituent tasks.
|
Class and Description |
---|
Deployer |
Operation
This is the interface which encapsulates an application instance that will be
deployed.
|
ProgressTracker
The
ProgressTracker encapsulates information about the status of
jobs. |
Class and Description |
---|
Operation
This is the interface which encapsulates an application instance that will be
deployed.
|
Class and Description |
---|
Deployer |
ExecutionProfile
This interfaces encapsulates the execution profile of the operation.
|
JobLifecycleObserver
JobLifecycleObserver is the interface which needs to be
implemented by an entity which wishes to observe the execution of a Job and
its constituent tasks. |
JobSubmission
This class manages the submission, tracking and cancellation of Jobs and
their constituent tasks.
|
Map
This interface corresponds to the Map role in a Map-Reduce operation.
|
MapReduce
This is an interface which encapsulates functionality that is common to both
the
Map and Reduce roles that are associated with
the applications. |
MapReduceException
This is the exception that would be thrown if there are problems in
performing Map-Reduce operations.
|
Operation
This is the interface which encapsulates an application instance that will be
deployed.
|
Operation.OperationType |
OperationBase
This is an implementation of the
Operation and
OperationConfiguration interfaces. |
OperationConfiguration
This is an interface that allows application instances to be configured.
|
ProcessingException
This exception is thrown when an operation wishes to report problems in its
execution.
|
ProgressTracker
The
ProgressTracker encapsulates information about the status of
jobs. |
Reduce
This interface corresponds to the Reduce role in a Map-Reduce
operation.
|
Class and Description |
---|
Operation
This is the interface which encapsulates an application instance that will be
deployed.
|
ProcessingException
This exception is thrown when an operation wishes to report problems in its
execution.
|
Class and Description |
---|
Map
This interface corresponds to the Map role in a Map-Reduce operation.
|
MapReduce
This is an interface which encapsulates functionality that is common to both
the
Map and Reduce roles that are associated with
the applications. |
MapReduceBase
This is the base class which will serve as the base for implementations of
the
Map and Reduce interface. |
Operation
This is the interface which encapsulates an application instance that will be
deployed.
|
OperationBase
This is an implementation of the
Operation and
OperationConfiguration interfaces. |
OperationConfiguration
This is an interface that allows application instances to be configured.
|
ProcessingException
This exception is thrown when an operation wishes to report problems in its
execution.
|
Reduce
This interface corresponds to the Reduce role in a Map-Reduce
operation.
|
Copyright © 2015. All rights reserved.