kieker.analysisteetime.plugin.reader.filesystem.fsReader

Class FSReader

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractProducerStage<IMonitoringRecord>

kieker.analysisteetime.plugin.reader.filesystem.fsReader.FSReader

All Implemented Interfaces:

IMonitoringRecordReceiver

Deprecated.

since 1.15 removed 1.16

@Deprecated
public class FSReader
extends teetime.framework.AbstractProducerStage<IMonitoringRecord>
implements IMonitoringRecordReceiver

Filesystem reader which reads from multiple directories simultaneously ordered by the logging timestamp.

Since:

0.95a

Author:

Andre van Hoorn, Jan Waller, Lars Bluemke

Field Summary

Fields inherited from class teetime.framework.AbstractProducerStage

outputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor and Description
FSReader(java.lang.String[] inputDirs, boolean ignoreUnknownRecordTypes) Deprecated. Creates an instance of this class using the given parameters.

Method Summary

Modifier and Type	Method and Description
protected void	execute() Deprecated.
boolean	isIgnoreUnknownRecordTypes() Deprecated.
void	newEndOfFileRecord() Deprecated.
boolean	newMonitoringRecord(IMonitoringRecord record) Deprecated. This method is called for each new record by each ReaderThread.
void	terminateStage() Deprecated.

Methods inherited from class teetime.framework.AbstractProducerStage

getOutputPort, getTerminationStrategy

Methods inherited from class teetime.framework.AbstractStage

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

Methods inherited from class java.lang.Object

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

Constructor Detail

FSReader

public FSReader(java.lang.String[] inputDirs,
                boolean ignoreUnknownRecordTypes)

Deprecated.

Creates an instance of this class using the given parameters.

Parameters:

inputDirs - Determines the input directories for this plugin.

ignoreUnknownRecordTypes - Determines whether the reader ignores unknown record types or not.

Method Detail

terminateStage

public void terminateStage()

Deprecated.

Overrides:

terminateStage in class teetime.framework.AbstractStage

execute

protected void execute()

Deprecated.

Specified by:

execute in class teetime.framework.AbstractStage

newMonitoringRecord

public boolean newMonitoringRecord(IMonitoringRecord record)

Deprecated.

Description copied from interface: IMonitoringRecordReceiver

This method is called for each new record by each ReaderThread.

Specified by:

newMonitoringRecord in interface IMonitoringRecordReceiver

Parameters:

record - The record to be processed.

Returns:

true if and only if the record has been handled correctly.

newEndOfFileRecord

public void newEndOfFileRecord()

Deprecated.

Specified by:

newEndOfFileRecord in interface IMonitoringRecordReceiver

isIgnoreUnknownRecordTypes

public boolean isIgnoreUnknownRecordTypes()

Deprecated.