teetime.stage.io

Class Directory2FilesFilter

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractConsumerStage<I>

teetime.stage.basic.AbstractTransformation<E,E>

teetime.stage.basic.AbstractFilter<File>

teetime.stage.io.Directory2FilesFilter

All Implemented Interfaces:

ITransformation<File,File>

public final class Directory2FilesFilter
extends AbstractFilter<File>

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
Directory2FilesFilter()
Directory2FilesFilter(Comparator<File> fileComparator)
Directory2FilesFilter(FileFilter fileFilter)
Directory2FilesFilter(FileFilter fileFilter, Comparator<File> fileComparator)

Method Summary

Modifier and Type	Method and Description
protected void	execute(File inputDir) Contains the logic of this stage and is invoked (possibly multiple times) by the framework.
Comparator<File>	getFileComparator()
FileFilter	getFilter()
void	setFileComparator(Comparator<File> fileComparator)
void	setFilter(FileFilter filter)

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

Directory2FilesFilter

public Directory2FilesFilter(FileFilter fileFilter)

Parameters:

fileFilter - to emit only files matching the filter.

Directory2FilesFilter

public Directory2FilesFilter(Comparator<File> fileComparator)

Parameters:

fileComparator - to sort the files before emitting each one by one.

Directory2FilesFilter

public Directory2FilesFilter(FileFilter fileFilter,
                             Comparator<File> fileComparator)

Parameters:

fileFilter - to emit only files matching the filter.

fileComparator - to sort the files before emitting each one by one.

Directory2FilesFilter

public Directory2FilesFilter()

Method Detail

execute

protected void execute(File inputDir)

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:

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

getFilter

public FileFilter getFilter()

setFilter

public void setFilter(FileFilter filter)

getFileComparator

public Comparator<File> getFileComparator()

setFileComparator

public void setFileComparator(Comparator<File> fileComparator)