public class SortDeployer extends InstanceDeployer
Constructor and Description |
---|
SortDeployer(java.util.Properties streamingProperties)
Initializes the deployer.
|
Modifier and Type | Method and Description |
---|---|
SortingOperation |
initializeSortingOperation(int postFix)
Initialize a specific
SortingOperation instance. |
SortMap |
initializeSortMap(SortReduce reduce,
int postFix)
Initializes a
SortMap instance based on the specified
arguments. |
static void |
main(java.lang.String[] args) |
void |
prepareBaseInstancesAndDeploy(int numOfOperations)
This method deploys vanilla
SortingOperation instances over
the set of available resources. |
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 SortDeployer(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 SortingOperation initializeSortingOperation(int postFix) throws DatasetException
SortingOperation
instance.postFix
- The instance ID for the instance in question.SortingOperation
instance.DatasetException
- If there are problems initializing the dataset.public void prepareBaseInstancesAndDeploy(int numOfOperations) throws DatasetException, CommunicationsException, DeploymentException, MarshallingException
SortingOperation
instances over
the set of available resources. This is different from the other
equivalent method in this class which deploys a set of Map/Reduce roles.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 SortMap initializeSortMap(SortReduce reduce, int postFix) throws DatasetException, MapReduceException
SortMap
instance based on the specified
arguments.reduce
- The reducer that would be associated with the map.postFix
- The map instance numberSortMap
instanceDatasetException
- If there are problems initializing/using the datasetsMapReduceException
- If there are problems related to Map/Reduce roles within the
application.public void prepareInstancesAndDeploy(int numOfMaps) throws MapReduceException, CommunicationsException, DeploymentException, MarshallingException, DatasetException, java.lang.InterruptedException
numOfMaps
- The number of Maps that need to be deployed.DatasetException
- If there are problems initializing the datasetsMapReduceException
- If there is a MapReduceExcecution because of problems when
setting up the roles.java.io.IOException
- If there are IO problems.CommunicationsException
- If there are network problems during communicationsDeploymentException
- If there are deployment related problemsMarshallingException
- If there are marshalling problems.java.lang.InterruptedException
- If there are problems sleepingpublic static void main(java.lang.String[] args)
args
-