Class GenericRecordIntFieldCopier

java.lang.Object
io.deephaven.kafka.ingest.GenericRecordFieldCopier
io.deephaven.kafka.ingest.GenericRecordIntFieldCopier
All Implemented Interfaces:
FieldCopier

public class GenericRecordIntFieldCopier extends GenericRecordFieldCopier
  • Constructor Details

    • GenericRecordIntFieldCopier

      public GenericRecordIntFieldCopier(String fieldPathStr, Pattern separator, org.apache.avro.Schema schema)
  • Method Details

    • copyField

      public void copyField(ObjectChunk<Object,Values> inputChunk, WritableChunk<Values> publisherChunk, int sourceOffset, int destOffset, int length)
      Description copied from interface: FieldCopier
      Copy fields from a chunk of Kafka key or value objects to a chunk that will be published to a blink table.
      Parameters:
      inputChunk - the chunk containing Kafka keys or values
      publisherChunk - the output chunk for the provided field
      sourceOffset - the source chunk offset
      destOffset - the destination chunk offset
      length - the length to copy