ds.granules.samples.wordcount

Class WordCountMap

java.lang.Object

ds.granules.operation.OperationBase

ds.granules.operation.MapReduceBase

ds.granules.samples.wordcount.WordCountMap

All Implemented Interfaces:

FormatMarshaller, Map, MapReduce, Operation, OperationConfiguration, Reduce

public class WordCountMap
extends MapReduceBase

An example demonstrating the Map 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
WordCountMap()

Method Summary

Modifier and Type	Method and Description
void	execute() Execute the operation.
void	initialize(java.util.Properties directives) 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

WordCountMap

public WordCountMap()

Method Detail

initialize

public void initialize(java.util.Properties directives)
                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:

directives - 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