teetime.stage.io

Class File2SeqOfWords

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractConsumerStage<I>

teetime.stage.basic.AbstractTransformation<File,String>

teetime.stage.io.File2SeqOfWords

All Implemented Interfaces:

ITransformation<File,String>

public final class File2SeqOfWords
extends AbstractTransformation<File,String>

Author:

Christian Wulf

Field Summary

Fields inherited from class teetime.stage.basic.AbstractTransformation

outputPort

Fields inherited from class teetime.framework.AbstractConsumerStage

inputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor and Description
File2SeqOfWords() charset = UTF-8 bufferCapacity = 1024
File2SeqOfWords(int bufferCapacity)
File2SeqOfWords(String charset, int bufferCapacity)

Method Summary

Modifier and Type	Method and Description
protected void	execute(File textFile) Contains the logic of this stage and is invoked (possibly multiple times) by the framework.
int	getBufferCapacity()
String	getCharset()

Methods inherited from class teetime.stage.basic.AbstractTransformation

getOutputPort

Methods inherited from class teetime.framework.AbstractConsumerStage

createInputPort, execute, getInputPort

Methods inherited from class teetime.framework.AbstractStage

abort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, createInputPort, createInputPort, createInputPort, createOutputPort, createOutputPort, createOutputPort, createOutputPort, declareActive, declarePassive, executeByFramework, getCurrentState, getId, getInputPorts, getOutputPorts, getOwningThread, getTerminationStrategy, isActive, isBeingExecuted, isPaused, isProducer, isStateless, onSignal, onStarting, onTerminating, onValidating, removeDynamicPort, removeDynamicPort, setPaused, setStateless, shouldBeTerminated, signalAlreadyReceived, terminateStage, toString, workCompleted

Methods inherited from class java.lang.Object

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

Methods inherited from interface teetime.stage.basic.ITransformation

getInputPort

Constructor Detail

File2SeqOfWords

public File2SeqOfWords()

1. charset = UTF-8
2. bufferCapacity = 1024

File2SeqOfWords

public File2SeqOfWords(int bufferCapacity)

File2SeqOfWords

public File2SeqOfWords(String charset,
                       int bufferCapacity)

Method Detail

execute

protected void execute(File textFile)

Description copied from class: AbstractConsumerStage

Contains the logic of this stage and is invoked (possibly multiple times) by the framework.

Specified by:

execute in class AbstractConsumerStage<File>

Parameters:

textFile - the next non-null element from the (only) input port of this stage

getCharset

public String getCharset()

getBufferCapacity

public int getBufferCapacity()