kieker.analysisteetime.plugin.reader.filesystem.fsReader

Class AsciiLogReader

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractProducerStage<IMonitoringRecord>

kieker.analysisteetime.plugin.reader.filesystem.fsReader.AsciiLogReader

All Implemented Interfaces:

IMonitoringRecordReceiver

Deprecated.

since 1.15 removed 1.16

@Deprecated
public class AsciiLogReader
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
AsciiLogReader(java.lang.String[] inputDirs, boolean ignoreUnknownRecordTypes, boolean shouldDecompress) Deprecated. Creates a new instance of this class using the given parameters.

Method Summary

Modifier and Type	Method and Description
protected void	execute() 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

AsciiLogReader

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

Deprecated.

Creates a new 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.

shouldDecompress - Determines whether to decompress the Kieker log files.

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.

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