public class Deployer extends InstanceDeployer
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
datasetIdentifier |
Constructor and Description |
---|
Deployer(java.util.Properties streamingProperties)
Initializes the deployer.
|
Modifier and Type | Method and Description |
---|---|
void |
deployHeartbeats(int numOfOperations) |
static void |
main(java.lang.String[] args) |
void |
prepareInstancesAndDeploy(int numOfOperations)
This method deploys
GalileoMap 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 static final java.lang.String datasetIdentifier
public Deployer(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 void prepareInstancesAndDeploy(int numOfOperations) throws DatasetException, CommunicationsException, DeploymentException, MarshallingException
GalileoMap
instances over the set of
available resources.numOfOperations
- Number of Speculators to startDatasetException
- 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 deployHeartbeats(int numOfOperations) throws DatasetException, CommunicationsException, DeploymentException, MarshallingException
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
-