public interface Map extends MapReduce
Modifier and Type | Method and Description |
---|---|
int |
addReduce(Reduce reduce)
Adds a Reduce for this particular Map.
|
int |
getNumberOfReducers()
Retrieves the number of registered Reduce instances
|
java.util.Enumeration<java.lang.String> |
getReduceIdentifiers()
Retrieves the set of Reduce identifiers
|
int |
removeReduce(java.lang.String reduceIdentifier)
Removes a given reducer from the list of Reducers for a given Map
function.
|
createResults, writeResults, writeResults, writeResults
dispose, execute, getBytes, getDatasetCollection, getDomain, getExecutionProfile, getInstanceIdentifier, getOperationIdentifier, getProcessingDirectives, getVersionInformation, hasDatasetCollection, hasExecutionProfile, hasProcessingDirectives, initialize, isInitialized, needsInitialization, terminationConditionReached, toString, unmarshall
int getNumberOfReducers()
java.util.Enumeration<java.lang.String> getReduceIdentifiers()
int addReduce(Reduce reduce) throws MapReduceException
reduce
- The Reducer that will be added to this MapMapReduceException
- If there are problems in adding this Reduce
java.lang.NullPointerException
- is the specified Reduce
is nullint removeReduce(java.lang.String reduceIdentifier) throws MapReduceException
reduceIdentifier
- The identifier of the Reduce to be removedMapReduceException
- If there are problems during removal.java.lang.NullPointerException
- is the specified Reduce
is null