Package kieker.analysis.generic.source.file

Class DatEventDeserializer

java.lang.Object

kieker.analysis.generic.source.file.AbstractEventDeserializer

kieker.analysis.generic.source.file.DatEventDeserializer

public class DatEventDeserializer
extends AbstractEventDeserializer

Since:

1.15

Author:

Reiner Jung

Field Summary

Fields

Modifier and Type	Field	Description
static final String	BUFFER_SIZE
static final int	DEFAULT_BUFFER_SIZE
static final String	PREFIX

Fields inherited from class kieker.analysis.generic.source.file.AbstractEventDeserializer

registry

Constructor Summary

Constructors

Constructor	Description
DatEventDeserializer(Integer bufferSize, ReaderRegistry<String> registry)

Method Summary

Modifier and Type	Method	Description
void	processDataStream(InputStream inputStream, teetime.framework.OutputPort<IMonitoringRecord> outputPort)	Read an input stream of data, deserialize it and output proper monitoring records.

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

BUFFER_SIZE

public static final String BUFFER_SIZE

DEFAULT_BUFFER_SIZE

public static final int DEFAULT_BUFFER_SIZE

See Also:

• Constant Field Values

Constructor Details

DatEventDeserializer

public DatEventDeserializer(Integer bufferSize,
 ReaderRegistry<String> registry)

Method Details

processDataStream

public void processDataStream(InputStream inputStream,
 teetime.framework.OutputPort<IMonitoringRecord> outputPort)
                       throws IOException

Description copied from class: AbstractEventDeserializer

Read an input stream of data, deserialize it and output proper monitoring records.

Specified by:

processDataStream in class AbstractEventDeserializer

Parameters:

inputStream - the input stream

outputPort - the output port

Throws:

IOException - on input stream errors