public class EEGDeployer extends InstanceDeployer
MODULE| Constructor and Description |
|---|
EEGDeployer() |
EEGDeployer(java.util.Properties streamingProperties)
Initializes the deployer.
|
| Modifier and Type | Method and Description |
|---|---|
EEGMap |
initializeEEGMap(EEGReduce reduce,
int computationID) |
static void |
main(java.lang.String[] args) |
void |
prepareInstancesAndDeploy(int numOfMaps) |
completedExecution, completedSuccessfully, completedWithErrors, createJobIdentifier, deployOperations, deployOperations, deployOperations, getStatus, initialize, initialize, initialize, killJob, refreshStatus, refreshStatus, resetTrackers, setStartTime, startedExecutionpublic EEGDeployer()
public EEGDeployer(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 EEGMap initializeEEGMap(EEGReduce reduce, int computationID) throws DatasetException, MapReduceException
DatasetExceptionMapReduceExceptionpublic void prepareInstancesAndDeploy(int numOfMaps)
throws DatasetException,
MapReduceException,
CommunicationsException,
DeploymentException,
MarshallingException
public static void main(java.lang.String[] args)
args -