public interface MapReduce extends Operation
Map
and Reduce
roles that are associated with
the applications.Modifier and Type | Method and Description |
---|---|
Results |
createResults(boolean completeResult,
boolean processingComplete)
Create the
Results type to be used for reporting results
produced as a result of the processing. |
void |
writeResults(int synopsisType,
java.lang.String streamSynopsis,
Results results)
Writes the specified results to a specific output stream.
|
void |
writeResults(Results results)
Writes the specified results to the default output stream.
|
void |
writeResults(java.lang.String streamSynopsis,
Results results)
Writes the specified results to a specific output stream.
|
dispose, execute, getBytes, getDatasetCollection, getDomain, getExecutionProfile, getInstanceIdentifier, getOperationIdentifier, getProcessingDirectives, getVersionInformation, hasDatasetCollection, hasExecutionProfile, hasProcessingDirectives, initialize, isInitialized, needsInitialization, terminationConditionReached, toString, unmarshall
Results createResults(boolean completeResult, boolean processingComplete)
Results
type to be used for reporting results
produced as a result of the processing.completeResult
- processingComplete
- Results
.void writeResults(Results results) throws MapReduceException
results
- The results to be written.MapReduceException
- If there are problems in marshalling or writing these
results.java.lang.NullPointerException
- If the specified results are null.void writeResults(java.lang.String streamSynopsis, Results results) throws MapReduceException
streamSynopsis
- The synopsis for the streamresults
- The results that needs to be writtenMapReduceException
- If there are problems in marshalling or writing these
results.java.lang.NullPointerException
- if the specified stream or the results are null.void writeResults(int synopsisType, java.lang.String streamSynopsis, Results results) throws MapReduceException
synopsisType
- The synopsis type for the stream in questionstreamSynopsis
- The synopsis for the streamresults
- The results that needs to be writtenMapReduceException
- If there are problems in marshalling or writing these
results.java.lang.NullPointerException
- if the specified stream or the results are null.