Package io.deephaven.extensions.barrage.util

Class BarrageProtoUtil.MessageInfo

java.lang.Object
io.deephaven.extensions.barrage.util.BarrageProtoUtil.MessageInfo
Enclosing class:
BarrageProtoUtil
public static final class BarrageProtoUtil.MessageInfo extends Object

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    io.deephaven.barrage.flatbuf.BarrageMessageWrapper
    app_metadata
    the embedded flatbuffer metadata indicating information about this batch
    org.apache.arrow.flight.impl.Flight.FlightDescriptor
    descriptor
    the parsed protobuf from the flight descriptor embedded in app_metadata
    org.apache.arrow.flatbuf.Message
    header
    outer-most Arrow Flight Message that indicates the msg type (i.e.
    com.google.common.io.LittleEndianDataInputStream
    inputStream
    the payload beyond the header metadata

  • Constructor Summary

    Constructors
    Constructor
    Description
    MessageInfo()
     

  • Method Summary

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Field Details

    • app_metadata

      public io.deephaven.barrage.flatbuf.BarrageMessageWrapper app_metadata
      the embedded flatbuffer metadata indicating information about this batch

    • descriptor

      public org.apache.arrow.flight.impl.Flight.FlightDescriptor descriptor
      the parsed protobuf from the flight descriptor embedded in app_metadata

    • inputStream

      public com.google.common.io.LittleEndianDataInputStream inputStream
      the payload beyond the header metadata

  • Constructor Details

    • MessageInfo

      public MessageInfo()