| Package | Description |
|---|---|
| ds.granules.exchange |
This package contains classes related to processing exchanges.
|
| ds.granules.interfere.computation | |
| ds.granules.interfere.computation.ecg | |
| ds.granules.interfere.computation.eeg | |
| ds.granules.interfere.computation.thorax | |
| ds.granules.interfere.placement.component | |
| ds.granules.operation |
This package encapsulates functionality related to application instances that will be deployed on the cloud.
|
| ds.granules.samples.uppercase |
This package contains a simple example which flips an input string from lowercase to uppercase.
|
| ds.granules.samples.wordcount |
This package contains classes that demonstrate using Granules with a simple information retrieval capability: Histogramming Word Counts in a set of files on a distributed set of machines.
|
| ds.granules.util |
This package contains utility classes used by several components.
|
| Modifier and Type | Method and Description |
|---|---|
DeploymentMessage |
ExchangeFactory.createDeploymentResponse(java.lang.String jobIdentifier,
java.lang.String taskIdentifier,
int exchangeSubType,
int conditionFlag,
java.lang.String description)
Creates a deployment response, to a previously issued request.
|
DeploymentMessage |
ExchangeFactory.createDeploymentStatusOrAbortRequest(java.lang.String jobIdentifier,
java.lang.String taskIdentifier,
java.lang.String respondTo,
int exchangeSubType)
Creates a DeploymentMessage that is a request for either getting the
STATUS or ABORTing a previously deployment operation.
|
DeploymentMessage |
ExchangeFactory.createDepoymentRequest(java.lang.String jobIdentifier,
Operation operation,
java.lang.String respondTo)
Creates a deployment request based on the specified parameters.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ComputationManager.deployJob(int inStreamGrp,
java.lang.String inDeployStream,
boolean inActive) |
void |
ComputationManager.terminateJob() |
| Modifier and Type | Method and Description |
|---|---|
void |
ECGDeployer.prepareInstancesAndDeploy(double percentActive,
int numMon)
This method deploys
RespirationMap instances over the set of
available resources. |
void |
ECGDeployer.terminateJob()
This method attempts to terminate the job that was previously submitted.
|
| Constructor and Description |
|---|
ECGDeployer(java.util.Properties streamingProperties)
Initializes the deployer.
|
| Modifier and Type | Method and Description |
|---|---|
void |
EEGDeployer.prepareInstancesAndDeploy(int numOfMaps) |
| Constructor and Description |
|---|
EEGDeployer(java.util.Properties streamingProperties)
Initializes the deployer.
|
| Modifier and Type | Method and Description |
|---|---|
void |
RespirationMonitorDeployer.prepareInstancesAndDeploy(double percentActive,
int numMon)
This method deploys
RespirationMap instances over the set of
available resources. |
void |
RespirationMonitorDeployer.terminateJob()
This method attempts to terminate the job that was previously submitted.
|
| Constructor and Description |
|---|
RespirationMonitorDeployer(java.util.Properties streamingProperties)
Initializes the deployer.
|
| Modifier and Type | Method and Description |
|---|---|
java.util.List<GIResourceTrackerImpl.ResourceState> |
GIResourceTrackerImpl.discoverResources(int inWaitSeconds) |
java.util.List<GIResourceTrackerImpl.ResourceState> |
GIResourceTrackerCmpnt.discoverResources(int inWaitSeconds) |
| Modifier and Type | Method and Description |
|---|---|
void |
JobSubmission.abortTask(java.lang.String jobIdentifier,
java.lang.String taskIdentifier)
Send an abort request for a specific task.
|
ProgressTracker |
JobSubmission.deploy(Operation[] operations,
int numOfResources,
java.lang.String jobIdentifier,
JobLifecycleObserver jobLifecycleObserver) |
ProgressTracker |
InstanceDeployer.deployOperations(Operation[] operations)
This method deploys a set of operations on a specified number of
resources.
|
ProgressTracker |
InstanceDeployer.deployOperations(Operation[] operations,
int numOfResources,
java.lang.String jobIdentifier)
This method deploys a set of operations on a specified number of
resources.
|
ProgressTracker |
InstanceDeployer.deployOperations(Operation[] operations,
java.lang.String jobIdentifier)
This method deploys a set of operations on the set of available
resources.
|
void |
JobSubmission.discoverResource()
Discovers the available computational resources.
|
void |
JobSubmission.discoverResource(int wait)
Discovers the available computational resources.
|
void |
JobSubmission.getStatusOfTask(java.lang.String jobIdentifier,
java.lang.String taskIdentifier)
Retrieve the status of a task.
|
void |
InstanceDeployer.initialize(java.util.Properties streamingProperties)
This initializes the deployer based on the specified argument.
|
void |
InstanceDeployer.initialize(java.util.Properties streamingProperties,
java.lang.String commType)
This initializes the deployer based on the specified arguments.
|
void |
InstanceDeployer.initialize(java.lang.String configurationFile,
int entityId,
java.util.Properties props,
java.lang.String commType)
This initializes the deployer based on the specified arguments.
|
void |
JobSubmission.killJob(java.lang.String jobIdentifier)
Attempts to kill the job while it is in execution at different sites
|
void |
InstanceDeployer.killJob(java.lang.String jobIdentifier)
Kill a Job with specified jobIdentifer
|
void |
InstanceDeployer.refreshStatus(java.lang.String jobIdentifier)
This method refreshes the status of various tasks that comprise a Job.
|
void |
InstanceDeployer.refreshStatus(java.lang.String jobIdentifier,
java.lang.String taskIdentifier)
This method refreshes the status of a specific task that is part of the
Job in question.
|
ProgressTracker |
JobSubmission.submit(Operation operation,
JobLifecycleObserver jobLifecycleObserver)
Submit the given operation for execution.
|
ProgressTracker |
JobSubmission.submit(Operation operation,
java.lang.String resourceDeploymentStream,
JobLifecycleObserver jobLifecycleObserver)
Submit the given operation for execution.
|
ProgressTracker |
JobSubmission.submit(Operation operation,
java.lang.String resourceDeploymentStream,
java.lang.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 |
|---|---|
void |
UpperCaseDeployer.prepareInstancesAndDeploy(int numOfOperations)
This method deploys
FlipMap instances over the set of
available resources. |
void |
UpperCaseDeployer.terminateJob()
This method attempts to terminate the job that was previously submitted.
|
| Constructor and Description |
|---|
UpperCaseDeployer()
Initializes the deployer.
|
| Modifier and Type | Method and Description |
|---|---|
void |
WordCountDeployer.prepareInstancesAndDeploy(int numOfMaps,
java.lang.String filenameBase)
Prepares a set of Map/Reduce instances for the WordCount example and
deploys it on the set of available resources.
|
| Constructor and Description |
|---|
WordCountDeployer()
Initializes the deployer.
|
| Modifier and Type | Method and Description |
|---|---|
java.util.Properties |
ParamsReader.getProperties(java.lang.String configFileLocation)
Constructs a set of properties from the specified configuration file.
|