public class Deployer extends InstanceDeployer
Constructor and Description |
---|
Deployer(java.util.Properties properties)
Constructor.
|
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)
Initialize the controller
|
Worker |
initializeWorker(int workerNum,
int number)
Initialize one worker
|
static void |
main(java.lang.String[] args) |
void |
prepareInstancesAndDeploy(int number)
Initialize the controller and all the workers
|
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
properties
- Contains parametersCommunicationsException
java.io.IOException
MarshallingException
DeploymentException
public Worker initializeWorker(int workerNum, int number) throws DatasetException, MapReduceException
workerNum
- Number of the current worker.number
- Number of total workers.DatasetException
MapReduceException
public Controller initializeController(int numOfWorkers) throws DatasetException, MapReduceException
numOfWorkers
- Total number of workersDatasetException
MapReduceException
public void prepareInstancesAndDeploy(int number)
number
- Number of total workers.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
- args[0] is host name of narada brokering. args[1] is port
number of narada brokering. args[2] is number of workers.
args[3] is the command line of the workers.