public class Speculator extends MapReduceBase
Modifier and Type | Field and Description |
---|---|
static int |
HEARTBEAT_INTERVAL_MS |
static java.lang.String |
HEARTBEAT_SYNOPSIS |
static int |
HOST_TIMEOUT_MS |
Constructor and Description |
---|
Speculator() |
Modifier and Type | Method and Description |
---|---|
void |
execute()
Execute the operation.
|
void |
initialize(java.util.Properties processingDirectives)
Initialize the operation based on the specified processing directives.
|
void |
processStreamPacket(NBEvent nbEvent)
Handles incoming events.
|
addMap, addMapper, addReduce, addReducer, createResults, getAwaitingOutputsFrom, getBytes, getDatasetCollection, getMapIdentifiers, getMapReduceDataset, getNumberOfMaps, getNumberOfReducers, getReduceIdentifiers, isAwaitingOutputs, removeMap, removeMapper, removeReduce, removeReducer, resetOutputTracker, setReceivedOutputFrom, unmarshall, writeResults, writeResults, writeResults
changeToExecuteFixedNumberOfTimes, changeToExecuteOnce, changeToExecutePeriodically, changeToExecuteWhenDataAvailable, changeToStayAlive, dispose, getDomain, getExecutionProfile, getInstanceIdentifier, getOperationIdentifier, getProcessingDirectives, getVersionInformation, hasDatasetCollection, hasExecutionProfile, hasProcessingDirectives, isInitialized, markInitializationAsComplete, needsInitialization, setAsExecuteFixedNumberOfTimes, setAsExecuteOnce, setAsExecutePeriodically, setAsExecuteWhenDataAvailable, setAsStayAlive, setDatasetCollection, setDomain, setInitializationComplete, setInitializationNeeded, setInstanceIdentifier, setOperationIdentifier, setProcessingDirectives, setTeminationConditionReached, setVersionInformation, terminationConditionReached, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
dispose, getDomain, getExecutionProfile, getInstanceIdentifier, getOperationIdentifier, getProcessingDirectives, getVersionInformation, hasDatasetCollection, hasExecutionProfile, hasProcessingDirectives, isInitialized, needsInitialization, terminationConditionReached, toString
public static final java.lang.String HEARTBEAT_SYNOPSIS
public static final int HEARTBEAT_INTERVAL_MS
public static final int HOST_TIMEOUT_MS
public void initialize(java.util.Properties processingDirectives)
Operation
initialize
in interface Operation
initialize
in class OperationBase
processingDirectives
- The specified processing directivespublic void execute() throws ProcessingException
Operation
execute
in interface Operation
execute
in class OperationBase
ProcessingException
- If there are problems executing the operation in question.public void processStreamPacket(NBEvent nbEvent) throws java.io.IOException, MarshallingException
java.io.IOException
MarshallingException