Package kieker.analysis.plugin.reader.newio

Class AbstractRawDataReader

java.lang.Object
kieker.analysis.analysisComponent.AbstractAnalysisComponent
kieker.analysis.plugin.AbstractPlugin
kieker.analysis.plugin.reader.AbstractReaderPlugin
kieker.analysis.plugin.reader.newio.AbstractRawDataReader
All Implemented Interfaces:
IAnalysisComponent, IPlugin, IReaderPlugin
Direct Known Subclasses:
KafkaReader
@Deprecated
public abstract class AbstractRawDataReader
extends AbstractReaderPlugin
Deprecated.
since 1.15.1 old plugin api
Abstract superclass for all readers which only read raw data to be processed by a configurable deserializer.
Since:
1.13
Author:
Holger Knoche

  • Constructor Details

    • AbstractRawDataReader

      public AbstractRawDataReader​(Configuration configuration, IProjectContext projectContext, java.lang.String deserializerClassName)
      Deprecated.
      Creates a new reader using the given data.
      Parameters:
      configuration - The configuration to use
      projectContext - The project context the reader runs in
      deserializerClassName - The class name of the deserializer to use

  • Method Details

    • decodeAndDeliverRecords

      protected void decodeAndDeliverRecords​(byte[] rawData, java.lang.String outputPortName)
      Deprecated.
      Decodes the given raw data using the configured deserializer and delivers them to the given output port.
      Parameters:
      rawData - The raw data to decode
      outputPortName - The output port name to send the decoded records to

    • decodeAndDeliverRecords

      protected void decodeAndDeliverRecords​(java.nio.ByteBuffer rawData, int dataSize, java.lang.String outputPortName)
      Deprecated.
      Decodes the given raw data using the configured deserializer and delivers them to the given output port.
      Parameters:
      rawData - The raw data to decode
      dataSize - The size of the data to decode
      outputPortName - The output port name to send the decoded records to