kieker.analysisteetime.plugin.reader.filesystem.fsReader

Class BinaryLogReader

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractProducerStage<IMonitoringRecord>

kieker.analysisteetime.plugin.reader.filesystem.fsReader.BinaryLogReader

All Implemented Interfaces:

IMonitoringRecordReceiver

Deprecated.

since 1.15 removed 1.16

@Deprecated
public class BinaryLogReader
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
BinaryLogReader(java.lang.String[] inputDirs, 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

BinaryLogReader

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

Deprecated.

Creates a new instance of this class using the given parameters.

Parameters:

configuration - The configuration for this component.

projectContext - The project context for this component.

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