public class ClusterDeployer extends InstanceDeployer
Constructor and Description |
---|
ClusterDeployer(java.util.Properties streamingProperties,
java.lang.String commType)
Initializes the deployer.
|
Modifier and Type | Method and Description |
---|---|
static void |
main(java.lang.String[] args) |
void |
prepareBaseInstancesAndDeploy(java.lang.String directory,
java.lang.String filenameBase,
int numOfMaps,
int numOfFiles)
Prepares a set of instances to be deployed.
|
completedExecution, completedSuccessfully, completedWithErrors, createJobIdentifier, deployOperations, deployOperations, deployOperations, getStatus, initialize, initialize, initialize, killJob, refreshStatus, refreshStatus, resetTrackers, setStartTime, startedExecution
public ClusterDeployer(java.util.Properties streamingProperties, java.lang.String commType) throws CommunicationsException, java.io.IOException, MarshallingException, DeploymentException
streamingProperties
- The properties for streamingcommType
- The communications typeCommunicationsException
- 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 void prepareBaseInstancesAndDeploy(java.lang.String directory, java.lang.String filenameBase, int numOfMaps, int numOfFiles) throws DatasetException, MapReduceException, java.io.IOException, CommunicationsException, DeploymentException, MarshallingException
directory
- The working directory of the subprocess where the command
would be executed.filenameBase
- The File which contains the list of files that need to be
processed.numOfMaps
- The total number of maps that will be deployed.numOfFiles
- The total number of files that have to be processed.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.public static void main(java.lang.String[] args)