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,
int up,
int down,
int left,
int right)
Initialize the controller
|
Worker |
initializeWorker(int workerNum,
int number,
int up,
int down,
int left,
int right)
Initialize one worker
|
static void |
main(java.lang.String[] args) |
void |
prepareInstancesAndDeploy(int number,
int up,
int down,
int left,
int right)
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, int up, int down, int left, int right) throws DatasetException, MapReduceException
workerNum
- Number of the current worker.number
- Number of total workers.up
- Upper bower of the region.down
- Lower bower of the region.left
- Left bower of the region.right
- Right bower of the region.DatasetException
MapReduceException
public Controller initializeController(int numOfWorkers, int up, int down, int left, int right) throws DatasetException, MapReduceException
numOfWorkers
- Total number of workersDatasetException
MapReduceException
public void prepareInstancesAndDeploy(int number, int up, int down, int left, int right)
number
- Number of total workers.up
- Upper bower of the regiondown
- Lower bower of the regionleft
- Left bower of the regionright
- Right bower of the regionpublic 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] through args[6] are upper, lower, left and right
boundaries of the area. args[7] is the command line of the
workers.