public class CBayesDeployer extends InstanceDeployer
Constructor and Description |
---|
CBayesDeployer(java.util.Properties streamingProperties)
Initializes the deployer.
|
Modifier and Type | Method and Description |
---|---|
static void |
main(java.lang.String[] args) |
void |
prepareInstancesAndDeploy(int mapStage1,
int mapStage2,
int mapStage3,
java.lang.String inDirectory,
java.lang.String outDirectory,
int numFiles,
java.lang.String fileList) |
completedExecution, completedSuccessfully, completedWithErrors, createJobIdentifier, deployOperations, deployOperations, deployOperations, getStatus, initialize, initialize, initialize, killJob, refreshStatus, refreshStatus, resetTrackers, setStartTime, startedExecution
public CBayesDeployer(java.util.Properties streamingProperties) throws CommunicationsException, java.io.IOException, MarshallingException, DeploymentException
streamingProperties
- properties for streamingDeploymentException
MarshallingException
java.io.IOException
CommunicationsException
public void prepareInstancesAndDeploy(int mapStage1, int mapStage2, int mapStage3, java.lang.String inDirectory, java.lang.String outDirectory, int numFiles, java.lang.String fileList) throws CommunicationsException, DeploymentException, MarshallingException, DatasetException, java.io.IOException, MapReduceException
CommunicationsException
DeploymentException
MarshallingException
DatasetException
java.io.IOException
MapReduceException
public static void main(java.lang.String[] args)