| 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.