public class ChecksumDeployer extends InstanceDeployer
Constructor and Description |
---|
ChecksumDeployer(java.util.Properties streamingProperties) |
Modifier and Type | Method and Description |
---|---|
static void |
main(java.lang.String[] args) |
void |
prepareInstancesAndDeploy(int numOfOperations)
This method deploys ChecksumMap instances over the set of
available resources.
|
void |
terminateJob()
This method attempts to terminate the job that was previously submitted.
|
completedExecution, completedSuccessfully, completedWithErrors, createJobIdentifier, deployOperations, deployOperations, deployOperations, getStatus, initialize, initialize, initialize, killJob, refreshStatus, refreshStatus, resetTrackers, setStartTime, startedExecution
public ChecksumDeployer(java.util.Properties streamingProperties) throws CommunicationsException, java.io.IOException, DatasetException, MarshallingException, DeploymentException
CommunicationsException
java.io.IOException
DatasetException
MarshallingException
DeploymentException
public void prepareInstancesAndDeploy(int numOfOperations) throws DatasetException, CommunicationsException, DeploymentException, MarshallingException
numOfOperations
- The total number of instances that need to be initialized.DatasetException
CommunicationsException
DeploymentException
MarshallingException
public void terminateJob() throws DeploymentException, CommunicationsException, MarshallingException
public static void main(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception