Uses of Class
ds.granules.exception.MarshallingException

Packages that use MarshallingException

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.

Uses of MarshallingException in ds.granules.exchange

Methods in ds.granules.exchange that throw MarshallingException

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

Uses of MarshallingException in ds.granules.interfere.computation

Methods in ds.granules.interfere.computation that throw MarshallingException

Modifier and Type	Method and Description
void	ComputationManager.deployJob(int inStreamGrp, java.lang.String inDeployStream, boolean inActive)
void	ComputationManager.terminateJob()

Uses of MarshallingException in ds.granules.interfere.computation.ecg

Methods in ds.granules.interfere.computation.ecg that throw MarshallingException

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.

Constructors in ds.granules.interfere.computation.ecg that throw MarshallingException

Constructor and Description
ECGDeployer(java.util.Properties streamingProperties) Initializes the deployer.

Uses of MarshallingException in ds.granules.interfere.computation.eeg

Methods in ds.granules.interfere.computation.eeg that throw MarshallingException

Modifier and Type	Method and Description
void	EEGDeployer.prepareInstancesAndDeploy(int numOfMaps)

Constructors in ds.granules.interfere.computation.eeg that throw MarshallingException

Constructor and Description
EEGDeployer(java.util.Properties streamingProperties) Initializes the deployer.

Uses of MarshallingException in ds.granules.interfere.computation.thorax

Methods in ds.granules.interfere.computation.thorax that throw MarshallingException

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.

Constructors in ds.granules.interfere.computation.thorax that throw MarshallingException

Constructor and Description
RespirationMonitorDeployer(java.util.Properties streamingProperties) Initializes the deployer.

Uses of MarshallingException in ds.granules.interfere.placement.component

Methods in ds.granules.interfere.placement.component that throw MarshallingException

Modifier and Type	Method and Description
java.util.List<GIResourceTrackerImpl.ResourceState>	GIResourceTrackerImpl.discoverResources(int inWaitSeconds)
java.util.List<GIResourceTrackerImpl.ResourceState>	GIResourceTrackerCmpnt.discoverResources(int inWaitSeconds)

Uses of MarshallingException in ds.granules.operation

Methods in ds.granules.operation that throw MarshallingException

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.

Uses of MarshallingException in ds.granules.results

Methods in ds.granules.results that throw MarshallingException

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

Uses of MarshallingException in ds.granules.samples.uppercase

Methods in ds.granules.samples.uppercase that throw MarshallingException

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.

Constructors in ds.granules.samples.uppercase that throw MarshallingException

Constructor and Description
UpperCaseDeployer() Initializes the deployer.

Uses of MarshallingException in ds.granules.samples.wordcount

Methods in ds.granules.samples.wordcount that throw MarshallingException

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.

Constructors in ds.granules.samples.wordcount that throw MarshallingException

Constructor and Description
WordCountDeployer() Initializes the deployer.