public class ChecksumMap extends MapReduceBase
Constructor and Description |
---|
ChecksumMap() |
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.
|
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 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.