public class GrepCountDeployer extends InstanceDeployer
Constructor and Description |
---|
GrepCountDeployer(java.util.Properties streamingProperties)
Initializes the deployer.
|
Modifier and Type | Method and Description |
---|---|
static void |
main(java.lang.String[] args) |
void |
prepareInstancesAndDeploy(int numOfMaps,
java.lang.String filenameBase,
int numOfFiles)
Prepares a set of Map/Reduce instances for the Grep example and deploys
it on the set of available resources.
|
completedExecution, completedSuccessfully, completedWithErrors, createJobIdentifier, deployOperations, deployOperations, deployOperations, getStatus, initialize, initialize, initialize, killJob, refreshStatus, refreshStatus, resetTrackers, setStartTime, startedExecution
public GrepCountDeployer(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 void prepareInstancesAndDeploy(int numOfMaps, java.lang.String filenameBase, int numOfFiles) throws MapReduceException, CommunicationsException, DeploymentException, MarshallingException, DatasetException, java.lang.InterruptedException
numOfMaps
- The total number of maps being deployedfilenameBase
- The directory in which the files are stored.numOfFiles
- The total number of files that need to be processedDatasetException
- 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
-