Class BodyCompression


public final class BodyCompression extends
Optional compression for the memory buffers constituting IPC message bodies. Intended for use with RecordBatch but could be used for other message types
  • Constructor Details

    • BodyCompression

      public BodyCompression()
  • Method Details

    • ValidateVersion

      public static void ValidateVersion()
    • getRootAsBodyCompression

      public static BodyCompression getRootAsBodyCompression(ByteBuffer _bb)
    • getRootAsBodyCompression

      public static BodyCompression getRootAsBodyCompression(ByteBuffer _bb, BodyCompression obj)
    • __init

      public void __init(int _i, ByteBuffer _bb)
    • __assign

      public BodyCompression __assign(int _i, ByteBuffer _bb)
    • codec

      public byte codec()
      Compressor library. For LZ4_FRAME, each compressed buffer must consist of a single frame.
    • method

      public byte method()
      Indicates the way the record batch body was compressed
    • createBodyCompression

      public static int createBodyCompression( builder, byte codec, byte method)
    • startBodyCompression

      public static void startBodyCompression( builder)
    • addCodec

      public static void addCodec( builder, byte codec)
    • addMethod

      public static void addMethod( builder, byte method)
    • endBodyCompression

      public static int endBodyCompression( builder)