kieker.tools.source

Class LogsReaderCompositeStage

java.lang.Object

teetime.framework.CompositeStage

kieker.tools.source.LogsReaderCompositeStage

All Implemented Interfaces:

ISourceCompositeStage

public class LogsReaderCompositeStage
extends teetime.framework.CompositeStage
implements ISourceCompositeStage

Read one or more Kieker log directories consecutively.

Since:

1.15

Author:

Reiner Jung

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DATA_BUFFER_SIZE
static java.lang.String	LOG_DIRECTORIES
static java.lang.String	PREFIX
static java.lang.String	VERBOSE

Fields inherited from class teetime.framework.CompositeStage

DEFAULT_PIPE_CAPACITY

Constructor Summary

Constructors

Constructor and Description
LogsReaderCompositeStage(Configuration configuration) Creates a composite stage to scan and read a set of Kieker log directories.
LogsReaderCompositeStage(java.util.List<java.io.File> directories, boolean verbose, java.lang.Integer dataBufferSize) Creates a composite stage to scan and read a set of Kieker log directories.

Method Summary

Modifier and Type	Method and Description
teetime.framework.OutputPort<IMonitoringRecord>	getOutputPort() get the output port of a source composite stage.

Methods inherited from class teetime.framework.CompositeStage

connectPorts, connectPorts, createInputPort, createOutputPort

Methods inherited from class java.lang.Object

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

Field Detail

PREFIX

public static final java.lang.String PREFIX

LOG_DIRECTORIES

public static final java.lang.String LOG_DIRECTORIES

DATA_BUFFER_SIZE

public static final java.lang.String DATA_BUFFER_SIZE

VERBOSE

public static final java.lang.String VERBOSE

Constructor Detail

LogsReaderCompositeStage

public LogsReaderCompositeStage(Configuration configuration)

Creates a composite stage to scan and read a set of Kieker log directories.

Parameters:

configuration - configuration for the enclosed filters

LogsReaderCompositeStage

public LogsReaderCompositeStage(java.util.List<java.io.File> directories,
                                boolean verbose,
                                java.lang.Integer dataBufferSize)

Creates a composite stage to scan and read a set of Kieker log directories.

Parameters:

directories - list of directories to read

verbose - report on every read log file

dataBufferSize - buffer size of the data file reader (null == use default setting)

Method Detail

getOutputPort

public teetime.framework.OutputPort<IMonitoringRecord> getOutputPort()

Description copied from interface: ISourceCompositeStage

get the output port of a source composite stage.

Specified by:

getOutputPort in interface ISourceCompositeStage

Returns:

the proper output port