public class PyCollDeployerRep extends InstanceDeployer
Constructor and Description |
---|
PyCollDeployerRep(java.util.Properties streamingProperties)
Initializes the deployer.
|
Modifier and Type | Method and Description |
---|---|
PyCollMap |
initializePyCollMap(PyCollReduceRep pcr,
int postFix,
java.lang.String pyProg,
int total)
Initialize a specific
FibMap instance. |
static void |
main(java.lang.String[] args) |
void |
prepareInstancesAndDeploy(int numOfOperations,
java.lang.String prog,
java.lang.String pyProg2,
java.lang.String fName,
int width,
int height,
int zoom,
java.lang.String fout,
java.lang.String description)
This method deploys
FibMap instances over the set of
available resources. |
completedExecution, completedSuccessfully, completedWithErrors, createJobIdentifier, deployOperations, deployOperations, deployOperations, getStatus, initialize, initialize, initialize, killJob, refreshStatus, refreshStatus, resetTrackers, setStartTime, startedExecution
public PyCollDeployerRep(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 errorsDeploymentException
- If there are deployment related problemspublic PyCollMap initializePyCollMap(PyCollReduceRep pcr, int postFix, java.lang.String pyProg, int total) throws DatasetException, java.io.IOException, MapReduceException
FibMap
instance.pcr
- postFix
- The instance ID for the instance in question.FibMap
instance.DatasetException
- If there are problems initializing the dataset.java.io.IOException
MapReduceException
public void prepareInstancesAndDeploy(int numOfOperations, java.lang.String prog, java.lang.String pyProg2, java.lang.String fName, int width, int height, int zoom, java.lang.String fout, java.lang.String description) throws DatasetException, CommunicationsException, DeploymentException, MarshallingException, java.io.IOException, MapReduceException
FibMap
instances over the set of
available resources.numOfOperations
- The total number of instances that need to be initialized.prog
- The program to be executed, including the path to reach it.fout
- zoom
- height
- width
- fName
- pyProg2
- description
- DatasetException
- If there are problems initializing the datasetsCommunicationsException
- If there are network problems during communicationsDeploymentException
- If there are deployment related problemsMarshallingException
- If there are marshalling problems.java.io.IOException
- If there is a problem connecting to the c program passed in
as a parameterMapReduceException
public static void main(java.lang.String[] args)
args
-