public class PeriodicDeployer extends InstanceDeployer
Constructor and Description |
---|
PeriodicDeployer(java.util.Properties streamingProperties)
Initializes the deployer.
|
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getJobId()
Retrieves the ID of the submitted Job
|
static void |
main(java.lang.String[] args) |
void |
prepareInstancesAndDeploy(int numOfMaps)
Prepares the set of Map/Reduce instances to be deployed on a set of
machines.
|
completedExecution, completedSuccessfully, completedWithErrors, createJobIdentifier, deployOperations, deployOperations, deployOperations, getStatus, initialize, initialize, initialize, killJob, refreshStatus, refreshStatus, resetTrackers, setStartTime, startedExecution
public PeriodicDeployer(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 errosDeploymentException
- If there are deployment related problemspublic java.lang.String getJobId()
public void prepareInstancesAndDeploy(int numOfMaps) throws MapReduceException, CommunicationsException, DeploymentException, MarshallingException
numOfMaps
- The number of Maps that need to be deployed.MapReduceException
- If there is a MapReduceExcecution because of problems when
setting up the roles.CommunicationsException
- If there are network problems during communicationsDeploymentException
- If there are deployment related problemsMarshallingException
- If there are marshalling problems.public static void main(java.lang.String[] args)
args
-