| 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.results |
Functionality for processing results generated by application instances.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
DeploymentMessage |
ExchangeFactory.getDeploymentMessage(byte[] exchangeBytes)
Reconstructs the Deployment Message from a stream of bytes
|
ExecutionStatus |
ExchangeFactory.getExecutionStatus(byte[] exchangeBytes)
Reconstruct the execution status object from a byte[].
|
ResourceDiscovery |
ExchangeFactory.getResourceDiscovery(byte[] exchangeBytes)
Reconstructs the
ResourceDiscovery from a stream of bytes |
| 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 |
|---|---|
byte[] |
ResultPayload.getBytes(double value)
This method converts a
double into a byte[]. |
byte[] |
ResultPayload.getBytes(double[] sequence)
This method converts a double[] into a byte[].
|
byte[] |
ResultPayload.getBytes(double[][] matrix)
This method converts a
double[][] into a byte[]
. |
byte[] |
ResultPayload.getBytes(float value)
This method converts a
float into a byte[]. |
byte[] |
ResultPayload.getBytes(float[] sequence)
This method converts a float[] into a byte[].
|
byte[] |
ResultPayload.getBytes(float[][] matrix)
This method converts a
float[][] into a byte[]. |
byte[] |
ResultPayload.getBytes(java.util.HashMap<?,?> sequence)
This method converts a HashMap into a byte[].
|
byte[] |
ResultPayload.getBytes(java.util.Hashtable<?,?> sequence)
This method converts a Hashtable into a byte[].
|
byte[] |
ResultPayload.getBytes(int value)
This method converts an
int into a byte[]. |
byte[] |
ResultPayload.getBytes(int[] sequence)
This method converts an int[] into a byte[].
|
byte[] |
ResultPayload.getBytes(int[][] matrix)
This method converts a
int[][] into a byte[]. |
byte[] |
ResultPayload.getBytes(long value)
This method converts a
long into a byte[]. |
byte[] |
ResultPayload.getBytes(long[] sequence)
This method converts a long[] into a byte[].
|
byte[] |
ResultPayload.getBytes(long[][] matrix)
This method converts a
long[][] into a byte[]. |
byte[] |
ResultPayload.getBytes(java.lang.Object[] sequence)
This method converts an
Object[] into a byte[]. |
byte[] |
ResultPayload.getBytes(short value)
This method converts a
short into a byte[]. |
byte[] |
ResultPayload.getBytes(short[] sequence)
This method converts a short[] into a byte[].
|
byte[] |
ResultPayload.getBytes(short[][] matrix)
This method converts a
short[][] into a byte[]. |
byte[] |
ResultPayload.getBytes(java.lang.String value)
This method converts a
String into a byte[]. |
byte[] |
ResultPayload.getBytes(java.lang.String[] sequence)
This method converts a String[] into a byte[].
|
double |
ResultPayload.getDouble(byte[] marshalledBytes)
This method converts a
byte[] into a double. |
double[][] |
ResultPayload.getDouble2DArray(byte[] marshalledBytes)
This method converts a
byte[] into a double[][]
. |
double[] |
ResultPayload.getDoubleArray(byte[] marshalledBytes)
This method converts a byte[] into a double[].
|
float |
ResultPayload.getFloat(byte[] marshalledBytes)
This method converts a
byte[] into a float. |
float[][] |
ResultPayload.getFloat2DArray(byte[] marshalledBytes)
This method converts a
byte[] into a float[][]. |
float[] |
ResultPayload.getFloatArray(byte[] marshalledBytes)
This method converts a byte[] into a float[].
|
java.util.HashMap<?,?> |
ResultPayload.getHashMap(byte[] marshalledBytes)
This method converts a byte[] into a HashMap.
|
java.util.Hashtable<?,?> |
ResultPayload.getHashtable(byte[] marshalledBytes)
This method converts a byte[] into a Hashtable.
|
int |
ResultPayload.getInt(byte[] marshalledBytes)
This method converts a
byte[] into an int. |
int[][] |
ResultPayload.getInt2DArray(byte[] marshalledBytes)
This method converts a
byte[] into a int[][]. |
int[] |
ResultPayload.getIntArray(byte[] marshalledBytes)
This method converts a byte[] into an int[].
|
long |
ResultPayload.getLong(byte[] marshalledBytes)
This method converts a
byte[] into a long. |
long[][] |
ResultPayload.getLong2DArray(byte[] marshalledBytes)
This method converts a
byte[] into a long[][]. |
long[] |
ResultPayload.getLongArray(byte[] marshalledBytes)
This method converts a byte[] into a long[].
|
java.lang.Object[] |
ResultPayload.getObjectArray(byte[] marshalledBytes)
This method converts a
byte[] into an Object[]. |
short |
ResultPayload.getShort(byte[] marshalledBytes)
This method converts a
byte[] into a short. |
short[][] |
ResultPayload.getShort2DArray(byte[] marshalledBytes)
This method converts a
byte[] into a short[][]. |
short[] |
ResultPayload.getShortArray(byte[] marshalledBytes)
This method converts a byte[] into a short[].
|
java.lang.String |
ResultPayload.getString(byte[] marshalledBytes)
This method converts a
byte[] into a String. |
java.lang.String[] |
ResultPayload.getStringArray(byte[] marshalledBytes)
This method converts a byte[] into a String[].
|
| 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.
|