kieker.analysis.source.file

Class AbstractEventDeserializer

java.lang.Object

kieker.analysis.source.file.AbstractEventDeserializer

Direct Known Subclasses:

BinaryEventDeserializer, DatEventDeserializer

public abstract class AbstractEventDeserializer
extends java.lang.Object

Abstract interface for the event deserialization.

Since:

1.15

Author:

Reiner Jung

Field Summary

Fields

Modifier and Type	Field and Description
protected ReaderRegistry<java.lang.String>	registry

Constructor Summary

Constructors

Constructor and Description
AbstractEventDeserializer(Configuration configuration, ReaderRegistry<java.lang.String> registry) Create an abstract event deserializer.

Method Summary

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

registry

protected final ReaderRegistry<java.lang.String> registry

Constructor Detail

AbstractEventDeserializer

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

Create an abstract event deserializer.

Parameters:

configuration - configuration for the deserializer.

registry - string registry to be used.

Method Detail

processDataStream

public abstract void processDataStream(java.io.InputStream chainInputStream,
                                       teetime.framework.OutputPort<IMonitoringRecord> outputPort)
                                throws java.io.IOException

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

Parameters:

chainInputStream - the input stream

outputPort - the output port

Throws:

java.io.IOException - on input stream errors