Class GenericRecordArrayFieldCopier

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

public class GenericRecordArrayFieldCopier extends GenericRecordFieldCopier
  • Constructor Details

    • GenericRecordArrayFieldCopier

      public GenericRecordArrayFieldCopier(String fieldPathStr, Pattern separator, org.apache.avro.Schema schema, Class<?> componentType)
  • 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