public interface MapReduce extends Operation
Map
and Reduce
roles that are associated with
the applications.Operation.OperationType
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,
String streamSynopsis,
Results results)
Deprecated.
|
void |
writeResults(Results results)
Writes the specified results to the default output stream.
|
void |
writeResults(String streamSynopsis,
Results results)
Deprecated.
|
void |
writeResults(ds.funnel.topic.Topic topic,
Results results)
Writes the specified results to a specific output stream.
|
dispose, execute, 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.NullPointerException
- If the specified results are null.void writeResults(ds.funnel.topic.Topic topic, Results results) throws MapReduceException
topic
- The topic to write results toresults
- The results that needs to be writtenMapReduceException
- If there are problems in marshalling or writing these results.NullPointerException
- If the specified stream or the results are null.@Deprecated void writeResults(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.NullPointerException
- If the specified stream or the results are null.@Deprecated void writeResults(int synopsisType, 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.NullPointerException
- If the specified stream or the results are null.Copyright © 2015. All rights reserved.