ds.granules.interfere.computation.ecg

Class ECGDeployer

java.lang.Object

ds.granules.operation.InstanceDeployer

ds.granules.interfere.computation.ecg.ECGDeployer

All Implemented Interfaces:

JobLifecycleObserver

public class ECGDeployer
extends InstanceDeployer

Field Summary

Fields inherited from class ds.granules.operation.InstanceDeployer

MODULE

Constructor Summary

Constructors

Constructor and Description
ECGDeployer()
ECGDeployer(java.util.Properties streamingProperties) Initializes the deployer.

Method Summary

Modifier and Type	Method and Description
ECGMonitor	initializeRespirationMap(int opGroup, int opIndex, int distinctOps, boolean isActive, boolean hasUpdates) Initialize a specific RespirationMap instance.
static void	main(java.lang.String[] args)
void	prepareInstancesAndDeploy(double percentActive, int numMon) This method deploys RespirationMap instances over the set of available resources.
void	terminateJob() This method attempts to terminate the job that was previously submitted.

Methods inherited from class ds.granules.operation.InstanceDeployer

completedExecution, completedSuccessfully, completedWithErrors, createJobIdentifier, deployOperations, deployOperations, deployOperations, getStatus, initialize, initialize, initialize, killJob, refreshStatus, refreshStatus, resetTrackers, setStartTime, startedExecution

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ECGDeployer

public ECGDeployer()

ECGDeployer

public ECGDeployer(java.util.Properties streamingProperties)
            throws CommunicationsException,
                   java.io.IOException,
                   MarshallingException,
                   DeploymentException

Initializes the deployer.

Parameters:

streamingProperties - The properties for streaming

Throws:

CommunicationsException - If there are network problems during communications

java.io.IOException - If there are IO problems

MarshallingException - If there are marshalling errors

DeploymentException - If there are deployment related problems

Method Detail

initializeRespirationMap

public ECGMonitor initializeRespirationMap(int opGroup,
                                           int opIndex,
                                           int distinctOps,
                                           boolean isActive,
                                           boolean hasUpdates)
                                    throws DatasetException

Initialize a specific RespirationMap instance. always assumes a single operation

Parameters:

postFix - The instance ID for the instance in question.

repLevel -

numPassive -

Returns:

The initialized RepTestMap instance.

Throws:

DatasetException - If there are problems initializing the dataset.

prepareInstancesAndDeploy

public void prepareInstancesAndDeploy(double percentActive,
                                      int numMon)
                               throws DatasetException,
                                      CommunicationsException,
                                      DeploymentException,
                                      MarshallingException

This method deploys RespirationMap instances over the set of available resources. assumes only a single operation

Parameters:

repLevel -

Throws:

DatasetException - If there are problems initializing the datasets

CommunicationsException - If there are network problems during communications

DeploymentException - If there are deployment related problems

MarshallingException - If there are marshalling problems.

terminateJob

public void terminateJob()
                  throws DeploymentException,
                         CommunicationsException,
                         MarshallingException

This method attempts to terminate the job that was previously submitted.

Throws:

DeploymentException - If there are deployment related problems

CommunicationsException - If there are network problems during communications

MarshallingException - If there are marshalling problems.

main

public static void main(java.lang.String[] args)

Parameters:

args -