ds.granules.samples.wordcount

Class WordCountReduce

java.lang.Object

ds.granules.operation.OperationBase

ds.granules.operation.MapReduceBase

ds.granules.samples.wordcount.WordCountReduce

All Implemented Interfaces:

FormatMarshaller, Map, MapReduce, Operation, OperationConfiguration, Reduce

public class WordCountReduce
extends MapReduceBase

An example demonstrating the Reduce role within a Word Count operation.

Author:

Shrideep Pallickara

Nested Class Summary

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

Operation.OperationType

Field Summary

Fields inherited from class ds.granules.operation.MapReduceBase

MODULE

Constructor Summary

Constructors

Constructor and Description
WordCountReduce()

Method Summary

Modifier and Type	Method and Description
void	execute() Execute the operation.
void	initialize(java.util.Properties providedDirectives) Initialize the operation based on the specified processing directives.

Methods inherited from class ds.granules.operation.MapReduceBase

addMap, addReduce, createResults, getAwaitingOutputsFrom, getDatasetCollection, getMapIdentifiers, getNumberOfMaps, getNumberOfReducers, getReduceIdentifiers, isAwaitingOutputs, marshall, removeMap, removeReduce, resetOutputTracker, setReceivedOutputFrom, unmarshall, writeResults, writeResults, writeResults, writeResults

Methods inherited from class ds.granules.operation.OperationBase

dispose, getDomain, getExecutionProfile, getInstanceIdentifier, getOperationIdentifier, getProcessingDirectives, getVersionInformation, hasDatasetCollection, hasExecutionProfile, hasProcessingDirectives, isInitialized, markInitializationAsComplete, needsInitialization, setAsExecuteFixedNumberOfTimes, setAsExecuteOnce, setAsExecutePeriodically, setAsExecuteWhenDataAvailable, setAsStayAlive, setDatasetCollection, setDomain, setInitializationComplete, setInitializationNeeded, setInstanceIdentifier, setOperationIdentifier, setProcessingDirectives, setTeminationConditionReached, setVersionInformation, terminationConditionReached, toString

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface ds.granules.operation.Operation

dispose, getDomain, getExecutionProfile, getInstanceIdentifier, getOperationIdentifier, getProcessingDirectives, getVersionInformation, hasDatasetCollection, hasExecutionProfile, hasProcessingDirectives, isInitialized, needsInitialization, terminationConditionReached, toString

Constructor Detail

WordCountReduce

public WordCountReduce()

Method Detail

initialize

public void initialize(java.util.Properties providedDirectives)
                throws ProcessingException

Description copied from interface: Operation

Initialize the operation based on the specified processing directives. The initialization will throw a ProcessingException is there are problems.

Specified by:

initialize in interface Operation

Specified by:

initialize in class OperationBase

Parameters:

providedDirectives - The specified processing directives

Throws:

ProcessingException - If there are problems initializing based on the specified processing directives.

execute

public void execute()

Description copied from interface: Operation

Execute the operation.

Specified by:

execute in interface Operation

Specified by:

execute in class OperationBase