public interface Reduce extends MapReduce
Modifier and Type | Method and Description |
---|---|
int |
addMap(Map map)
Adds a Map that will be reduced.
|
java.util.Iterator<java.lang.String> |
getAwaitingOutputsFrom()
Retrieves the set of Map identifiers from which an Output has not been
received so far.
|
java.util.Enumeration<java.lang.String> |
getMapIdentifiers()
Retrieves the set of Map identifiers
|
int |
getNumberOfMaps()
Retrieves the number of registered Map instances
|
boolean |
isAwaitingOutputs()
Check to see is the Reducer is missing outputs from any of the registered
Maps.
|
int |
removeMap(java.lang.String mapIdentifier)
Removes a Map from the list of Maps that are registered to this reducer.
|
void |
resetOutputTracker()
This method resets the output tracker associated with the reducer.
|
void |
setReceivedOutputFrom(java.lang.String mapIdentifier)
Mark the receipt of Output from a given Map instance
|
createResults, writeResults, writeResults, writeResults
dispose, execute, getBytes, getDatasetCollection, getDomain, getExecutionProfile, getInstanceIdentifier, getOperationIdentifier, getProcessingDirectives, getVersionInformation, hasDatasetCollection, hasExecutionProfile, hasProcessingDirectives, initialize, isInitialized, needsInitialization, terminationConditionReached, toString, unmarshall
int getNumberOfMaps()
Map
sjava.util.Enumeration<java.lang.String> getMapIdentifiers()
boolean isAwaitingOutputs()
true
is the Reducer is still awaiting outputs;
false
otherwise.java.util.Iterator<java.lang.String> getAwaitingOutputsFrom()
void resetOutputTracker()
void setReceivedOutputFrom(java.lang.String mapIdentifier)
mapIdentifier
- The ID of the Map from which an output has been received.int addMap(Map map) throws MapReduceException
map
- Add a Map instance for this reducerMapReduceException
int removeMap(java.lang.String mapIdentifier) throws MapReduceException
mapIdentifier
- The identifier of the Map to removedMapReduceException
- If there are problems removing the Map.