ds.granules.operation

Interface MapReduce

All Superinterfaces:

ds.funnel.data.format.FormatMarshaller, Operation

All Known Subinterfaces:

Map, Reduce

All Known Implementing Classes:

MapReduceBase, StreamBase, StreamProcessor, StreamSource

public interface MapReduce
extends Operation

This is an interface which encapsulates functionality that is common to both the Map and Reduce roles that are associated with the applications.

Author:

Shrideep Pallickara

Nested Class Summary

Nested classes/interfaces inherited from interface ds.granules.operation.Operation

Operation.OperationType

Method Summary

Methods

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.

Methods inherited from interface ds.granules.operation.Operation

dispose, execute, getDatasetCollection, getDomain, getExecutionProfile, getInstanceIdentifier, getOperationIdentifier, getProcessingDirectives, getVersionInformation, hasDatasetCollection, hasExecutionProfile, hasProcessingDirectives, initialize, isInitialized, needsInitialization, terminationConditionReached, toString, unmarshall

Methods inherited from interface ds.funnel.data.format.FormatMarshaller

marshall

Method Detail

createResults

Results createResults(boolean completeResult,
                    boolean processingComplete)

Create the Results type to be used for reporting results produced as a result of the processing.

Parameters:

completeResult -

processingComplete -

Returns:

The created Results.

writeResults

void writeResults(Results results)
                  throws MapReduceException

Writes the specified results to the default output stream.

Parameters:

results - The results to be written.

Throws:

MapReduceException - If there are problems in marshalling or writing these results.

NullPointerException - If the specified results are null.

writeResults

void writeResults(ds.funnel.topic.Topic topic,
                Results results)
                  throws MapReduceException

Writes the specified results to a specific output stream.

Parameters:

topic - The topic to write results to

results - The results that needs to be written

Throws:

MapReduceException - If there are problems in marshalling or writing these results.

NullPointerException - If the specified stream or the results are null.

writeResults

@Deprecated
void writeResults(String streamSynopsis,
                           Results results)
                  throws MapReduceException

Deprecated.

Writes the specified results to a specific output stream.

Parameters:

streamSynopsis - The synopsis for the stream

results - The results that needs to be written

Throws:

MapReduceException - If there are problems in marshalling or writing these results.

NullPointerException - If the specified stream or the results are null.

writeResults

@Deprecated
void writeResults(int synopsisType,
                           String streamSynopsis,
                           Results results)
                  throws MapReduceException

Deprecated.

Writes the specified results to a specific output stream.

Parameters:

synopsisType - The synopsis type for the stream in question

streamSynopsis - The synopsis for the stream

results - The results that needs to be written

Throws:

MapReduceException - If there are problems in marshalling or writing these results.

NullPointerException - If the specified stream or the results are null.