Uses of Class
ds.granules.exception.CommunicationsException

Packages that use CommunicationsException

Package	Description
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.scheduler	This package contains functionality related to scheduling the application instances.
ds.granules.util	This package contains utility classes used by several components.

Uses of CommunicationsException in ds.granules.interfere.computation

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

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

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

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

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 CommunicationsException

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

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

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

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

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

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

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

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

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 CommunicationsException

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

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

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

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 CommunicationsException in ds.granules.operation

Methods in ds.granules.operation that throw CommunicationsException

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	JobSubmission.initialize(java.lang.String configurationFile, int entityId, java.util.Properties props, java.lang.String commType) Initializes communications based on the specified parameters.
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 CommunicationsException in ds.granules.samples.uppercase

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

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 CommunicationsException

Constructor and Description
UpperCaseDeployer() Initializes the deployer.

Uses of CommunicationsException in ds.granules.samples.wordcount

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

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 CommunicationsException

Constructor and Description
WordCountDeployer() Initializes the deployer.

Uses of CommunicationsException in ds.granules.scheduler

Methods in ds.granules.scheduler that throw CommunicationsException

Modifier and Type	Method and Description
void	ExchangeProcessor.initialize()

Constructors in ds.granules.scheduler that throw CommunicationsException

Constructor and Description
Diagnostics(java.lang.String deploymentStream, int numOfThreads)

Uses of CommunicationsException in ds.granules.util

Methods in ds.granules.util that throw CommunicationsException

Modifier and Type	Method and Description
void	StreamPublisher.publishToStream(java.lang.String publishStream, byte[] transferBytes) Utility method that allows a producer to publish a set of bytes onto the specified stream.