public class FibDeployer extends InstanceDeployer
Constructor and Description |
---|
FibDeployer(java.util.Properties streamingProperties)
Initializes the deployer.
|
Modifier and Type | Method and Description |
---|---|
FibMap |
initializeFibMap(int postFix,
java.lang.String cProg,
int commType)
Initialize a specific
FibMap instance. |
static void |
main(java.lang.String[] args) |
void |
prepareInstancesAndDeploy(int numOfOperations,
java.lang.String prog,
int commType)
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 FibDeployer(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 FibMap initializeFibMap(int postFix, java.lang.String cProg, int commType) throws DatasetException, java.io.IOException
FibMap
instance.postFix
- The instance ID for the instance in question.commType
- FibMap
instance.DatasetException
- If there are problems initializing the dataset.java.io.IOException
public void prepareInstancesAndDeploy(int numOfOperations, java.lang.String prog, int commType) throws DatasetException, CommunicationsException, DeploymentException, MarshallingException, java.io.IOException
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.commType
- 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 parameterpublic static void main(java.lang.String[] args)
args
-