ds.granules.interfere.computation

Class GIComputation

java.lang.Object

ds.granules.operation.OperationBase

ds.granules.operation.MapReduceBase

ds.granules.interfere.computation.GIComputation

All Implemented Interfaces:

FormatMarshaller, Map, MapReduce, Operation, OperationConfiguration, Reduce

Direct Known Subclasses:

ECGMonitor, EEGMap, EEGReduce, GzipComputation, RespirationMap

public abstract class GIComputation
extends MapReduceBase

Nested Class Summary

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

Operation.OperationType

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.concurrent.ConcurrentHashMap<java.lang.String,java.lang.String>	check
static java.lang.String	DATASET_ID
static boolean	debugSubActive
static java.lang.ThreadLocal<java.lang.String>	trace

Fields inherited from class ds.granules.operation.MapReduceBase

MODULE

Constructor Summary

Constructors

Constructor and Description
GIComputation()

Method Summary

Modifier and Type	Method and Description
void	execute() Execute the operation.
ComputationDescription	getDescription()
static int	getID(java.lang.String s)
java.lang.String	getJobID()
ComputationStats	getStats()
ComputationUsage	getUsage()
void	initialize(java.util.Properties providedDirectives) Initialize the operation based on the specified processing directives.
void	marshall(FormatWriter mFormat)
void	setDetails(GIPlacementDetails inServDetails, ComputationDescription inCompDesc, java.lang.String inJobID, boolean inActive, GIPlacementNode.Migration inMigrConf, java.lang.String inDebID)
void	setInitializationComplete() Mark the initialization of the application as having completed
void	setTeminationConditionReached() Mark the termination condition of this operation as having reached.
void	startMigration(double inScore)
void	unmarshall(FormatReader mFormat) Unmarshall the operation from a set of marshalled bytes.

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

Field Detail

DATASET_ID

public static final java.lang.String DATASET_ID

See Also:

Constant Field Values

debugSubActive

public static volatile boolean debugSubActive

check

public static final java.util.concurrent.ConcurrentHashMap<java.lang.String,java.lang.String> check

trace

public static final java.lang.ThreadLocal<java.lang.String> trace

Constructor Detail

GIComputation

public GIComputation()

Method Detail

unmarshall

public void unmarshall(FormatReader mFormat)
                throws FormatException

Description copied from interface: Operation

Unmarshall the operation from a set of marshalled bytes.

Specified by:

unmarshall in interface Operation

Overrides:

unmarshall in class MapReduceBase

Parameters:

mFormat - The byte[] representation of the operation.

Throws:

FormatException

marshall

public void marshall(FormatWriter mFormat)
              throws FormatException

Specified by:

marshall in interface FormatMarshaller

Overrides:

marshall in class MapReduceBase

Parameters:

mFormat - - The format writer to write to

Throws:

FormatException - If there was a problem while writing

setDetails

public void setDetails(GIPlacementDetails inServDetails,
                       ComputationDescription inCompDesc,
                       java.lang.String inJobID,
                       boolean inActive,
                       GIPlacementNode.Migration inMigrConf,
                       java.lang.String inDebID)

getJobID

public java.lang.String getJobID()

getDescription

public ComputationDescription getDescription()

getUsage

public ComputationUsage getUsage()

getStats

public ComputationStats getStats()

initialize

public final void initialize(java.util.Properties providedDirectives)
                      throws ProcessingException

Description copied from interface: Operation

Initialize the operation based on the specified processing directives. The initialization will throw a ProcessingException is there are problems.

Specified by:

initialize in interface Operation

Specified by:

initialize in class OperationBase

Parameters:

providedDirectives - The specified processing directives

Throws:

ProcessingException - If there are problems initializing based on the specified processing directives.

execute

public final void execute()
                   throws ProcessingException

Description copied from interface: Operation

Execute the operation.

Specified by:

execute in interface Operation

Specified by:

execute in class OperationBase

Throws:

ProcessingException - If there are problems executing the operation in question.

startMigration

public void startMigration(double inScore)
                    throws MapReduceException

Throws:

MapReduceException

setInitializationComplete

public void setInitializationComplete()

Description copied from interface: OperationConfiguration

Mark the initialization of the application as having completed

Specified by:

setInitializationComplete in interface OperationConfiguration

Overrides:

setInitializationComplete in class OperationBase

setTeminationConditionReached

public void setTeminationConditionReached()

Description copied from interface: OperationConfiguration

Mark the termination condition of this operation as having reached. If the execution profile of the operation is isStayAlive() the operation cannot be garbage collected till such time that this flag has been set.

Specified by:

setTeminationConditionReached in interface OperationConfiguration

Overrides:

setTeminationConditionReached in class OperationBase

getID

public static int getID(java.lang.String s)