ds.granules.samples.uppercase

Class UpperCaseDeployer

java.lang.Object

ds.granules.operation.InstanceDeployer

ds.granules.samples.uppercase.UpperCaseDeployer

All Implemented Interfaces:

JobLifecycleObserver

public class UpperCaseDeployer
extends InstanceDeployer

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	MODULE_

Fields inherited from class ds.granules.operation.InstanceDeployer

MODULE

Constructor Summary

Constructors

Constructor and Description
UpperCaseDeployer() Initializes the deployer.

Method Summary

Modifier and Type	Method and Description
UpperCaseMap	initializeFlipMap(int postFix) Initialize a specific FlipMap instance.
static void	main(java.lang.String[] args)
void	prepareInstancesAndDeploy(int numOfOperations) This method deploys FlipMap instances over the set of available resources.
void	terminateJob() This method attempts to terminate the job that was previously submitted.

Methods inherited from class ds.granules.operation.InstanceDeployer

completedExecution, completedSuccessfully, completedWithErrors, createJobIdentifier, deployOperations, deployOperations, deployOperations, getStatus, initialize, initialize, initialize, killJob, refreshStatus, refreshStatus, resetTrackers, setStartTime, startedExecution

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MODULE_

public static final java.lang.String MODULE_

See Also:

Constant Field Values

Constructor Detail

UpperCaseDeployer

public UpperCaseDeployer()
                  throws CommunicationsException,
                         java.io.IOException,
                         MarshallingException,
                         DeploymentException

Initializes the deployer.

Parameters:

streamingProperties - The properties for streaming

Throws:

CommunicationsException - If there are network problems during communications

java.io.IOException - If there are IO problems

MarshallingException - If there are marshalling errors

DeploymentException - If there are deployment related problems

Method Detail

main

public static void main(java.lang.String[] args)

prepareInstancesAndDeploy

public void prepareInstancesAndDeploy(int numOfOperations)
                               throws DatasetException,
                                      CommunicationsException,
                                      DeploymentException,
                                      MarshallingException

This method deploys FlipMap instances over the set of available resources.

Parameters:

numOfOperations - The total number of instances that need to be initialized.

Throws:

DatasetException - If there are problems initializing the datasets

CommunicationsException - If there are network problems during communications

DeploymentException - If there are deployment related problems

MarshallingException - If there are marshalling problems.

initializeFlipMap

public UpperCaseMap initializeFlipMap(int postFix)
                               throws DatasetException

Initialize a specific FlipMap instance.

Parameters:

postFix - The instance ID for the instance in question.

Returns:

The initialized FlipMap instance.

Throws:

DatasetException - If there are problems initializing the dataset.

terminateJob

public void terminateJob()
                  throws DeploymentException,
                         CommunicationsException,
                         MarshallingException

This method attempts to terminate the job that was previously submitted.

Throws:

DeploymentException - If there are deployment related problems

CommunicationsException - If there are network problems during communications

MarshallingException - If there are marshalling problems.