Package io.deephaven.kafka.ingest

Interface KeyOrValueProcessor

All Known Implementing Classes:
GenericRecordChunkAdapter, JsonNodeChunkAdapter, MultiFieldChunkAdapter
public interface KeyOrValueProcessor

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    handleChunk(ObjectChunk<Object,Values> inputChunk, WritableChunk<Values>[] publisherChunks)
    After consuming a set of generic records for a batch that are not raw objects, we pass the keys or values to an appropriate handler.

  • Method Details

    • handleChunk

      void handleChunk(ObjectChunk<Object,Values> inputChunk, WritableChunk<Values>[] publisherChunks)
      After consuming a set of generic records for a batch that are not raw objects, we pass the keys or values to an appropriate handler. The handler must know its data types and offsets within the publisher chunks, and "copy" the data from the inputChunk to the appropriate chunks for the stream publisher.
      Parameters:
      inputChunk - the chunk containing the keys or values as Kafka deserialized them from the consumer record
      publisherChunks - the output chunks for this table that must be appended to.