public class Deployer extends InstanceDeployer
Constructor and Description |
---|
Deployer(java.util.Properties properties) |
Modifier and Type | Method and Description |
---|---|
void |
completedSuccessfully(java.lang.String jobIdentifier,
ProgressTracker progressTracker)
This method is invoked when all the constituent distributed tasks have
finished executing successfully.
|
Controller |
initializeController(int numOfWorkers) |
Worker |
initializeWorker(int workerNum,
int number,
int up,
int down,
int left,
int right) |
static void |
main(java.lang.String[] args) |
void |
prepareInstancesAndDeploy(int number,
int up,
int down,
int left,
int right) |
completedExecution, completedWithErrors, createJobIdentifier, deployOperations, deployOperations, deployOperations, getStatus, initialize, initialize, initialize, killJob, refreshStatus, refreshStatus, resetTrackers, setStartTime, startedExecution
public Deployer(java.util.Properties properties) throws CommunicationsException, java.io.IOException, MarshallingException, DeploymentException
CommunicationsException
java.io.IOException
MarshallingException
DeploymentException
public Worker initializeWorker(int workerNum, int number, int up, int down, int left, int right) throws DatasetException, MapReduceException
DatasetException
MapReduceException
public Controller initializeController(int numOfWorkers) throws DatasetException, MapReduceException
DatasetException
MapReduceException
public void prepareInstancesAndDeploy(int number, int up, int down, int left, int right)
public void completedSuccessfully(java.lang.String jobIdentifier, ProgressTracker progressTracker)
JobLifecycleObserver
completedSuccessfully
in interface JobLifecycleObserver
completedSuccessfully
in class InstanceDeployer
jobIdentifier
- The ID of the Job being reported onprogressTracker
- Contains information about the lifecycle metrics associated
with the constituent tasks.public static void main(java.lang.String[] args)
args
-