ds.granules.interfere.computation.ecg

Class ECGMonitor

java.lang.Object

ds.granules.operation.OperationBase

ds.granules.operation.MapReduceBase

ds.granules.interfere.computation.GIComputation

ds.granules.interfere.computation.ecg.ECGMonitor

All Implemented Interfaces:

FormatMarshaller, JavaMessageHandler, Map, MapReduce, Operation, OperationConfiguration, Reduce, java.io.Serializable

public class ECGMonitor
extends GIComputation
implements JavaMessageHandler, java.io.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface ds.granules.operation.Operation

Operation.OperationType

Field Summary

Fields inherited from class ds.granules.interfere.computation.GIComputation

check, DATASET_ID, debugSubActive, trace

Fields inherited from class ds.granules.operation.MapReduceBase

MODULE

Constructor Summary

Constructors

Constructor and Description
ECGMonitor()

Method Summary

Modifier and Type	Method and Description
void	handleMessage(byte[] msg) Function to handle messages recieved via a StreamReader.
void	RespirationMapInit()

Methods inherited from class ds.granules.interfere.computation.GIComputation

execute, getDescription, getID, getJobID, getStats, getUsage, initialize, marshall, setDetails, setInitializationComplete, setTeminationConditionReached, startMigration, unmarshall

Methods inherited from class ds.granules.operation.MapReduceBase

addMap, addReduce, createResults, getAwaitingOutputsFrom, getDatasetCollection, getMapIdentifiers, getNumberOfMaps, getNumberOfReducers, getReduceIdentifiers, isAwaitingOutputs, removeMap, removeReduce, resetOutputTracker, setReceivedOutputFrom, writeResults, writeResults, writeResults, writeResults

Methods inherited from class ds.granules.operation.OperationBase

dispose, getDomain, getExecutionProfile, getInstanceIdentifier, getOperationIdentifier, getProcessingDirectives, getVersionInformation, hasDatasetCollection, hasExecutionProfile, hasProcessingDirectives, isInitialized, markInitializationAsComplete, needsInitialization, setAsExecuteFixedNumberOfTimes, setAsExecuteOnce, setAsExecutePeriodically, setAsExecuteWhenDataAvailable, setAsStayAlive, setDatasetCollection, setDomain, setInitializationNeeded, setInstanceIdentifier, setOperationIdentifier, setProcessingDirectives, setVersionInformation, terminationConditionReached, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface ds.granules.operation.Operation

dispose, getDomain, getExecutionProfile, getInstanceIdentifier, getOperationIdentifier, getProcessingDirectives, getVersionInformation, hasDatasetCollection, hasExecutionProfile, hasProcessingDirectives, isInitialized, needsInitialization, terminationConditionReached, toString

Constructor Detail

ECGMonitor

public ECGMonitor()

Method Detail

RespirationMapInit

public void RespirationMapInit()

handleMessage

public void handleMessage(byte[] msg)

Description copied from interface: JavaMessageHandler

Function to handle messages recieved via a StreamReader. Allows the user to define an asynchronous method of handling messages

Specified by:

handleMessage in interface JavaMessageHandler

Parameters:

msg - byte[] to be decoded