Class JsonNodeShortFieldCopier

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

public class JsonNodeShortFieldCopier extends Object implements FieldCopier
  • Constructor Details

    • JsonNodeShortFieldCopier

      public JsonNodeShortFieldCopier(String fieldPointerStr)
  • 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.
      Specified by:
      copyField in interface FieldCopier
      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