public class FlipDeployer extends InstanceDeployer
Constructor and Description |
---|
FlipDeployer(java.util.Properties streamingProperties)
Initializes the deployer.
|
Modifier and Type | Method and Description |
---|---|
FlipMap |
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.
|
completedExecution, completedSuccessfully, completedWithErrors, createJobIdentifier, deployOperations, deployOperations, deployOperations, getStatus, initialize, initialize, initialize, killJob, refreshStatus, refreshStatus, resetTrackers, setStartTime, startedExecution
public FlipDeployer(java.util.Properties streamingProperties) throws CommunicationsException, java.io.IOException, MarshallingException, DeploymentException
streamingProperties
- The properties for streamingCommunicationsException
- If there are network problems during communicationsjava.io.IOException
- If there are IO problemsMarshallingException
- If there are marshalling errorsDeploymentException
- If there are deployment related problemspublic FlipMap initializeFlipMap(int postFix) throws DatasetException
FlipMap
instance.postFix
- The instance ID for the instance in question.FlipMap
instance.DatasetException
- If there are problems initializing the dataset.public void prepareInstancesAndDeploy(int numOfOperations) throws DatasetException, CommunicationsException, DeploymentException, MarshallingException
FlipMap
instances over the set of
available resources.numOfOperations
- The total number of instances that need to be initialized.DatasetException
- If there are problems initializing the datasetsCommunicationsException
- If there are network problems during communicationsDeploymentException
- If there are deployment related problemsMarshallingException
- If there are marshalling problems.public void terminateJob() throws DeploymentException, CommunicationsException, MarshallingException
DeploymentException
- If there are deployment related problemsCommunicationsException
- If there are network problems during communicationsMarshallingException
- If there are marshalling problems.public static void main(java.lang.String[] args)
args
-