kieker.analysis.source.file

Class DatEventDeserializer

java.lang.Object

kieker.analysis.source.file.AbstractEventDeserializer

kieker.analysis.source.file.DatEventDeserializer

public class DatEventDeserializer
extends AbstractEventDeserializer

Since:

1.15

Author:

Reiner Jung

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	BUFFER_SIZE
static int	DEFAULT_BUFFER_SIZE
static java.lang.String	PREFIX

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

registry

Constructor Summary

Constructors

Constructor and Description
DatEventDeserializer(Configuration configuration, ReaderRegistry<java.lang.String> registry)

Method Summary

Modifier and Type	Method and Description
void	processDataStream(java.io.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 Detail

PREFIX

public static final java.lang.String PREFIX

BUFFER_SIZE

public static final java.lang.String BUFFER_SIZE

DEFAULT_BUFFER_SIZE

public static final int DEFAULT_BUFFER_SIZE

See Also:

Constant Field Values

Constructor Detail

DatEventDeserializer

public DatEventDeserializer(Configuration configuration,
                            ReaderRegistry<java.lang.String> registry)

Method Detail

processDataStream

public void processDataStream(java.io.InputStream inputStream,
                              teetime.framework.OutputPort<IMonitoringRecord> outputPort)
                       throws java.io.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:

java.io.IOException - on input stream errors