Uses of Class
ds.granules.exception.MarshallingException

Packages that use MarshallingException

Package	Description
ds.granules.communication.direct
ds.granules.exchange	This package contains classes related to processing exchanges.
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.

Uses of MarshallingException in ds.granules.communication.direct

Methods in ds.granules.communication.direct that throw MarshallingException

Modifier and Type	Method and Description
ProgressTracker	JobDeployer.deployOperations(Operation[] operations)
static JobDeployer	JobDeployer.getInstance()
void	JobDeployer.initialize(Properties streamingProperties)

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

Methods in ds.granules.operation that throw MarshallingException

Modifier and Type	Method and Description
void	JobSubmission.abortTask(String jobIdentifier, String taskIdentifier) Send an abort request for a specific task.
ProgressTracker	JobSubmission.deploy(Operation[] operations, int numOfResources, String jobIdentifier, JobLifecycleObserver jobLifecycleObserver)
ProgressTracker	InstanceDeployer.deployOperations(Operation[] operations) This method deploys a set of operations on a specified number of resources.
ProgressTracker	Deployer.deployOperations(Operation[] operations)
ProgressTracker	InstanceDeployer.deployOperations(Operation[] operations, int numOfResources, String jobIdentifier) This method deploys a set of operations on a specified number of resources.
ProgressTracker	InstanceDeployer.deployOperations(Operation[] operations, 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(String jobIdentifier, String taskIdentifier) Retrieve the status of a task.
void	InstanceDeployer.initialize(Properties streamingProperties) This initializes the deployer based on the specified argument.
void	Deployer.initialize(Properties streamingProperties)
void	InstanceDeployer.initialize(Properties streamingProperties, String commType) This initializes the deployer based on the specified arguments.
void	InstanceDeployer.initialize(String configurationFile, int entityId, Properties props, String commType) This initializes the deployer based on the specified arguments.
void	JobSubmission.killJob(String jobIdentifier) Attempts to kill the job while it is in execution at different sites
void	InstanceDeployer.killJob(String jobIdentifier) Kill a Job with specified jobIdentifer
void	InstanceDeployer.refreshStatus(String jobIdentifier) This method refreshes the status of various tasks that comprise a Job.
void	InstanceDeployer.refreshStatus(String jobIdentifier, 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, String resourceDeploymentStream, JobLifecycleObserver jobLifecycleObserver) Submit the given operation for execution.
ProgressTracker	JobSubmission.submit(Operation operation, String resourceDeploymentStream, 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(HashMap<?,?> sequence) This method converts a HashMap into a byte[].
byte[]	ResultPayload.getBytes(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(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(String value) This method converts a String into a byte[].
byte[]	ResultPayload.getBytes(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[].
HashMap<?,?>	ResultPayload.getHashMap(byte[] marshalledBytes) This method converts a byte[] into a HashMap.
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[].
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[].
String	ResultPayload.getString(byte[] marshalledBytes) This method converts a byte[] into a String.
String[]	ResultPayload.getStringArray(byte[] marshalledBytes) This method converts a byte[] into a String[].