teetime.stage.string

Class WordCounter

java.lang.Object

teetime.framework.CompositeStage

teetime.stage.string.WordCounter

All Implemented Interfaces:

CompositeStateLoggable, ITransformation<String,CountingMap<String>>, ITaskFarmDuplicable<String,CountingMap<String>>

public class WordCounter
extends CompositeStage
implements ITaskFarmDuplicable<String,CountingMap<String>>, CompositeStateLoggable

Intermediate stage, which receives texts and counts the occurring words. The result (a CountingMap) is passed on upon termination.

Since:

1.1

Author:

Nelson Tavares de Sousa

Field Summary

Fields inherited from class teetime.framework.CompositeStage

DEFAULT_PIPE_CAPACITY

Constructor Summary

Constructors

Constructor and Description
WordCounter()

Method Summary

Modifier and Type	Method and Description
ITaskFarmDuplicable<String,CountingMap<String>>	duplicate() Creates a new instance of the enclosed stage.
InputPort<String>	getInputPort()
OutputPort<CountingMap<String>>	getOutputPort()
void	registerStatebles()

Methods inherited from class teetime.framework.CompositeStage

connectPorts, connectPorts, createInputPort, createOutputPort

Methods inherited from class java.lang.Object

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

Constructor Detail

WordCounter

public WordCounter()

Method Detail

getInputPort

public InputPort<String> getInputPort()

Specified by:

getInputPort in interface ITransformation<String,CountingMap<String>>

Specified by:

getInputPort in interface ITaskFarmDuplicable<String,CountingMap<String>>

Returns:

single input port of the enclosed stage

getOutputPort

public OutputPort<CountingMap<String>> getOutputPort()

Specified by:

getOutputPort in interface ITransformation<String,CountingMap<String>>

Specified by:

getOutputPort in interface ITaskFarmDuplicable<String,CountingMap<String>>

Returns:

single output port of the enclosed stage

duplicate

public ITaskFarmDuplicable<String,CountingMap<String>> duplicate()

Description copied from interface: ITaskFarmDuplicable

Creates a new instance of the enclosed stage.

Specified by:

duplicate in interface ITaskFarmDuplicable<String,CountingMap<String>>

Returns:

new instance

registerStatebles

public void registerStatebles()

Specified by:

registerStatebles in interface CompositeStateLoggable