Package kieker.analysis.plugin.reader.newio

Class RawDataReaderPlugin

java.lang.Object
kieker.analysis.analysisComponent.AbstractAnalysisComponent
kieker.analysis.plugin.AbstractPlugin
kieker.analysis.plugin.reader.AbstractReaderPlugin
kieker.analysis.plugin.reader.newio.RawDataReaderPlugin
All Implemented Interfaces:
IAnalysisComponent, IPlugin, IReaderPlugin, IRawDataProcessor
@Deprecated
public class RawDataReaderPlugin
extends AbstractReaderPlugin
implements IRawDataProcessor
Deprecated.
since 1.15.1 old plugin api
Generic reader plugin for the new raw data I/O infrastructure.
Since:
1.13
Author:
Holger Knoche

  • Field Details

  • Constructor Details

  • Method Details

    • getCurrentConfiguration

      public Configuration getCurrentConfiguration()
      Deprecated.
      Description copied from class: AbstractAnalysisComponent
      This method should deliver a Configuration object containing the current configuration of this instance. In other words: The constructor should be able to use the given object to initialize a new instance of this class with the same intern properties.
      Specified by:
      getCurrentConfiguration in interface IAnalysisComponent
      Specified by:
      getCurrentConfiguration in interface IPlugin
      Specified by:
      getCurrentConfiguration in class AbstractAnalysisComponent
      Returns:
      A completely filled configuration object.

    • init

      public boolean init()
      Deprecated.
      Description copied from class: AbstractReaderPlugin
      Initiates the start of a component. This method is called once when a AnalysisController's run() method is called. This implementation must not be blocking! Asynchronous consumers would spawn (an) asynchronous thread(s) in this method.
      Specified by:
      init in interface IPlugin
      Overrides:
      init in class AbstractReaderPlugin
      Returns:
      true on success; false otherwise.

    • read

      public boolean read()
      Deprecated.
      Description copied from interface: IReaderPlugin
      Starts the reader. This method is intended to be a blocking operation, i.e., it is assumed that reading has finished before this method returns. The method should indicate an error by the return value false. In asynchronous scenarios, the IPlugin.terminate(boolean) method can be used to initiate the termination of this method.
      Specified by:
      read in interface IReaderPlugin
      Returns:
      true if reading was successful; false if an error occurred

    • terminate

      public void terminate​(boolean error)
      Deprecated.
      Description copied from interface: IPlugin
      Initiates a termination of the plugin. This method is only used by the framework and should not be called manually. Use the method AnalysisController.terminate(boolean) instead. After receiving this notification, the plugin should terminate any running methods, e.g., read for readers.
      Specified by:
      terminate in interface IPlugin
      Parameters:
      error - Determines whether the plugin is terminated due to an error or not.

    • decodeAndDeliverRecords

      public void decodeAndDeliverRecords​(byte[] rawData)
      Deprecated.
      Description copied from interface: IRawDataProcessor
      Decodes the given raw data and delivers the decoded records.
      Specified by:
      decodeAndDeliverRecords in interface IRawDataProcessor
      Parameters:
      rawData - The raw data to decode

    • decodeAndDeliverRecords

      public void decodeAndDeliverRecords​(java.nio.ByteBuffer rawData, int dataSize)
      Deprecated.
      Description copied from interface: IRawDataProcessor
      Decodes the given raw data and delivers the decoded records.
      Specified by:
      decodeAndDeliverRecords in interface IRawDataProcessor
      Parameters:
      rawData - The raw data to decode
      dataSize - The size of the contained data