Package | Description |
---|---|
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 |
---|---|
abstract void |
OperationBase.execute() |
void |
Operation.execute()
Execute the operation.
|
abstract void |
OperationBase.initialize(Properties providedDirectives) |
void |
Operation.initialize(Properties processingDirectives)
Initialize the operation based on the specified processing directives.
|
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 | Method and Description |
---|---|
void |
StreamSource.execute() |
void |
StreamProcessor.execute() |
void |
StreamBase.initialize(Properties providedDirectives) |
Copyright © 2015. All rights reserved.