Package io.deephaven.kafka.ingest

Interface FieldCopier

All Known Implementing Classes:
GenericRecordArrayFieldCopier, GenericRecordBigDecimalFieldCopier, GenericRecordBooleanFieldCopier, GenericRecordByteFieldCopier, GenericRecordCharFieldCopier, GenericRecordDoubleFieldCopier, GenericRecordFieldCopier, GenericRecordFloatFieldCopier, GenericRecordInstantArrayFieldCopier, GenericRecordIntFieldCopier, GenericRecordLongFieldCopier, GenericRecordLongFieldCopierWithMultiplier, GenericRecordObjectFieldCopier, GenericRecordShortFieldCopier, GenericRecordStringFieldCopier, JsonNodeBooleanFieldCopier, JsonNodeByteFieldCopier, JsonNodeCharFieldCopier, JsonNodeDoubleFieldCopier, JsonNodeFloatFieldCopier, JsonNodeInstantFieldCopier, JsonNodeIntFieldCopier, JsonNodeJsonNodeFieldCopier, JsonNodeLongFieldCopier, JsonNodeShortFieldCopier, JsonNodeStringFieldCopier
public interface FieldCopier
Copy fields from a chunk of Kafka key or value objects to a chunk that will be published to a blink table.

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Interface
    Description
    static interface 
    FieldCopier.Factory
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    copyField(ObjectChunk<Object,Values> inputChunk, WritableChunk<Values> publisherChunk, int sourceOffset, int destOffset, int length)
    Copy fields from a chunk of Kafka key or value objects to a chunk that will be published to a blink table.

  • Method Details

    • copyField

      void copyField(ObjectChunk<Object,Values> inputChunk, WritableChunk<Values> publisherChunk, int sourceOffset, int destOffset, int length)
      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