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 |
---|---|
void |
deploy(ClusterMap[] maps) |
static void |
main(java.lang.String[] args) |
ClusterMap[] |
prepareBaseInstances(java.lang.String directory,
int numOfMaps,
java.lang.String herd_file,
java.lang.String sc_file)
Prepares a set of instances to be deployed.
|
void |
timeUp() |
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)
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 ClusterMap[] prepareBaseInstances(java.lang.String directory, int numOfMaps, java.lang.String herd_file, java.lang.String sc_file)
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 void deploy(ClusterMap[] maps)
public void timeUp()
public static void main(java.lang.String[] args)