public class LDADeployer extends InstanceDeployer
Constructor and Description |
---|
LDADeployer(java.util.Properties streamingProperties)
Initializes the deployer.
|
Modifier and Type | Method and Description |
---|---|
static void |
main(java.lang.String[] args) |
void |
prepareInstancesAndDeploy(int numMaps,
java.lang.String directory,
int numOfFiles,
java.lang.String fileList,
int iters,
java.lang.String delta,
java.lang.String dm,
java.lang.String clusterFile,
java.lang.String alpha)
Prepares and deploys Mappers and a Reducer
|
completedExecution, completedSuccessfully, completedWithErrors, createJobIdentifier, deployOperations, deployOperations, deployOperations, getStatus, initialize, initialize, initialize, killJob, refreshStatus, refreshStatus, resetTrackers, setStartTime, startedExecution
public LDADeployer(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 numMaps, java.lang.String directory, int numOfFiles, java.lang.String fileList, int iters, java.lang.String delta, java.lang.String dm, java.lang.String clusterFile, java.lang.String alpha) throws MapReduceException, CommunicationsException, DeploymentException, MarshallingException, DatasetException, java.lang.InterruptedException, java.io.IOException
numMaps
- The number of LDAMapper
s that need to be
initialized.filenameBase
- The directory in which the files are stored.numOfFiles
- The total number of files that need to be processedfileList
- List of Files to be processessed.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)