public interface Reduce extends MapReduce
Operation.OperationType
Modifier and Type | Method and Description |
---|---|
int |
addMap(Map map)
Adds a Map that will be reduced.
|
Iterator<String> |
getAwaitingOutputsFrom()
Retrieves the set of Map identifiers from which an Output has not been
received so far.
|
Enumeration<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(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(String mapIdentifier)
Mark the receipt of Output from a given Map instance
|
createResults, writeResults, writeResults, writeResults, writeResults
dispose, execute, getDatasetCollection, getDomain, getExecutionProfile, getInstanceIdentifier, getOperationIdentifier, getProcessingDirectives, getVersionInformation, hasDatasetCollection, hasExecutionProfile, hasProcessingDirectives, initialize, isInitialized, needsInitialization, terminationConditionReached, toString, unmarshall
int getNumberOfMaps()
Map
sEnumeration<String> getMapIdentifiers()
boolean isAwaitingOutputs()
true
is the Reducer is still awaiting outputs;
false
otherwise.Iterator<String> getAwaitingOutputsFrom()
void resetOutputTracker()
void setReceivedOutputFrom(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(String mapIdentifier) throws MapReduceException
mapIdentifier
- The identifier of the Map to removedMapReduceException
- If there are problems removing the Map.Copyright © 2015. All rights reserved.