Package 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	Description
static final String	DATA_BUFFER_SIZE
static final String	LOG_DIRECTORIES
static final String	PREFIX
static final String	VERBOSE

Fields inherited from class teetime.framework.CompositeStage

DEFAULT_PIPE_CAPACITY

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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 Details

PREFIX

public static final String PREFIX

LOG_DIRECTORIES

public static final String LOG_DIRECTORIES

DATA_BUFFER_SIZE

public static final String DATA_BUFFER_SIZE

VERBOSE

public static final String VERBOSE

Constructor Details

LogsReaderCompositeStage

@Deprecated
public LogsReaderCompositeStage(Configuration configuration)

Deprecated.

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

Parameters:

configuration - configuration for the enclosed filters

LogsReaderCompositeStage

public LogsReaderCompositeStage(List<File> directories,
 boolean verbose,
 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)

LogsReaderCompositeStage

public LogsReaderCompositeStage(File directory,
 boolean verbose,
 Integer dataBufferSize)

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

Parameters:

directory - 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 Details

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