kieker.analysis.source.file

Class DirectoryReaderStage

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractConsumerStage<I>

teetime.stage.basic.AbstractTransformation<java.io.File,IMonitoringRecord>

kieker.analysis.source.file.DirectoryReaderStage

All Implemented Interfaces:

teetime.stage.basic.ITransformation<java.io.File,IMonitoringRecord>

public class DirectoryReaderStage
extends teetime.stage.basic.AbstractTransformation<java.io.File,IMonitoringRecord>

Read a kieker log directory. The filter receives a directory as input and outputs all events collected in the directory.

Since:

1.15

Author:

Reiner Jung

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
DirectoryReaderStage(Configuration configuration) Create a new directory reader stage.

Method Summary

Modifier and Type	Method and Description
protected void	execute(java.io.File directory)

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

DirectoryReaderStage

public DirectoryReaderStage(Configuration configuration)

Create a new directory reader stage.

Parameters:

configuration - configuration for the stage and its plugins

Method Detail

execute

protected void execute(java.io.File directory)

Specified by:

execute in class teetime.framework.AbstractConsumerStage<java.io.File>