Package io.deephaven.kafka.ingest.protobuf

Class ProtobufRecord

java.lang.Object
io.deephaven.kafka.ingest.protobuf.ProtobufRecord
public class ProtobufRecord extends Object

  • Constructor Details

    • ProtobufRecord

      public ProtobufRecord(@NotNull com.google.protobuf.Message protoBuf, @NotNull org.apache.kafka.clients.consumer.ConsumerRecord<?,?> consumerRecord, boolean allowMissingKeys, boolean allowNullValues, boolean caseInsensitiveSearch)

  • Method Details

    • getMessage

      public com.google.protobuf.Message getMessage()

    • getProtoBuf

      public com.google.protobuf.Message getProtoBuf()

    • getConsumerRecord

      public org.apache.kafka.clients.consumer.ConsumerRecord<?,?> getConsumerRecord()

    • getAllowMissingKeys

      public boolean getAllowMissingKeys()

    • getAllowNullValues

      public boolean getAllowNullValues()

    • getDescriptorForKey

      public com.google.protobuf.Descriptors.FieldDescriptor getDescriptorForKey(@NotNull String key)

    • getArraySize

      public int getArraySize(@NotNull String key)

    • setParallelIdx

      public void setParallelIdx(int parallelIdx)

    • getParallelIdx

      public int getParallelIdx()

    • getValue

      public Object getValue(@NotNull String key)

    • getValue

      @ScriptApi public Object getValue(@NotNull String key, @NotNull Class<?> columnClass)