ptolemy.actor.ptalon.lib
Class WordCount

java.lang.Object
  java.lang.Thread
      ptolemy.actor.ptalon.lib.MapReduceAlgorithm
          ptolemy.actor.ptalon.lib.WordCount

All Implemented Interfaces:

java.lang.Runnable

public class WordCount
extends MapReduceAlgorithm

Word Count.

Since:

Ptolemy II 6.1

Version:

$Id: WordCount.java 45840 2007-04-12 03:34:42Z cxh $

Author:

Adam Cataldo

Accepted Rating:

Red (cxh)

Proposed Rating:

Red (cxh)

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class ptolemy.actor.ptalon.lib.MapReduceAlgorithm

reduceKey, reduceOutput, reduceValues

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

WordCount()

Method Summary

java.util.List<KeyValuePair>	map(java.lang.String key, java.lang.String value) Subclasses should implement their map method here.
java.util.List<java.lang.String>	reduce(java.lang.String key, java.util.concurrent.BlockingQueue<java.lang.String> values) Subclasses should implement their reduce method here, calling the take method of the BlockingQueue to get the next value, and checking the parameter noMoreInputs to test if no more values can be put on the queue.

Methods inherited from class ptolemy.actor.ptalon.lib.MapReduceAlgorithm

isQueueEmpty, isReduceFinished, run, setNoMoreInputs

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

WordCount

public WordCount()

Method Detail

map

public java.util.List<KeyValuePair> map(java.lang.String key,
                                        java.lang.String value)

Description copied from class: MapReduceAlgorithm

Subclasses should implement their map method here.

Specified by:

map in class MapReduceAlgorithm

Parameters:

key - The key passed to the map method.

value - The value passed to the map method.

Returns:

The list of key value pairs for the given input.

reduce

public java.util.List<java.lang.String> reduce(java.lang.String key,
                                               java.util.concurrent.BlockingQueue<java.lang.String> values)
                                        throws java.lang.InterruptedException

Description copied from class: MapReduceAlgorithm

Subclasses should implement their reduce method here, calling the take method of the BlockingQueue to get the next value, and checking the parameter noMoreInputs to test if no more values can be put on the queue. The last value put on the queue may be the empty string. If this is the case, just discard it.

Specified by:

reduce in class MapReduceAlgorithm

Parameters:

key - The key to reduce over.

values - The queue of values in reduction.

Returns:

The reduced list of valeus.

Throws:

java.lang.InterruptedException - If thrown while reducing.