Class ChunkAssembler.ValueBytesAndSchemaId

java.lang.Object
com.linkedin.venice.hadoop.input.kafka.chunk.ChunkAssembler.ValueBytesAndSchemaId
Enclosing class:
ChunkAssembler

public static class ChunkAssembler.ValueBytesAndSchemaId extends Object
  • Method Details

    • getBytes

      public byte[] getBytes()
    • getSchemaID

      public int getSchemaID()
    • getReplicationMetadataVersionId

      public int getReplicationMetadataVersionId()
    • getReplicationMetadataPayload

      public ByteBuffer getReplicationMetadataPayload()
    • setReplicationMetadataPayload

      public void setReplicationMetadataPayload(ByteBuffer replicationMetadataPayload)
    • setBytes

      public void setBytes(byte[] bytes)