Interface DataInputOutputSerde<E>


public interface DataInputOutputSerde<E>
Implementations read and write objects from/to the stream.
  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final EPTypeClass
    Type information
  • Method Summary

    Modifier and Type
    Method
    Description
    read(DataInput input, byte[] unitKey)
    Read an object from the stream.
    void
    write(E object, DataOutput output, byte[] unitKey, EventBeanCollatedWriter writer)
    Write an object to the stream.
  • Field Details

    • EPTYPE

      static final EPTypeClass EPTYPE
      Type information
  • Method Details

    • write

      void write(E object, DataOutput output, byte[] unitKey, EventBeanCollatedWriter writer) throws IOException
      Write an object to the stream.
      Parameters:
      object - to write or null if this is a nullable value
      output - to write to
      unitKey - the page key of the page containing the object, can be null if not relevant or not provided
      writer - the writer for events, can be null if not relevant or not provided
      Throws:
      IOException - for io exceptions
    • read

      E read(DataInput input, byte[] unitKey) throws IOException
      Read an object from the stream.
      Parameters:
      input - input to read
      unitKey - the identifying key of the reader, can be null if not relevant or not provided
      Returns:
      object read or null if this is a nullable value
      Throws:
      IOException - for io exceptions