kieker.analysis.source.file

Class BinaryEventDeserializer

java.lang.Object

kieker.analysis.source.file.AbstractEventDeserializer

kieker.analysis.source.file.BinaryEventDeserializer

public class BinaryEventDeserializer
extends AbstractEventDeserializer

This deserializer reads a binary input stream and deserializes them into IMonitoringRecords.

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

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

registry

Constructor Summary

Constructors

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

Method Summary

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

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

BinaryEventDeserializer

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

Method Detail

processDataStream

public void processDataStream(java.io.InputStream chainInputStream,
                              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:

chainInputStream - the input stream

outputPort - the output port

Throws:

java.io.IOException - on input stream errors