io.deephaven.kafka.ingest.protobuf.ProtobufRecord

public class ProtobufRecord
extends Object

Constructor Summary

Constructors
Constructor	Description
`ProtobufRecord(com.google.protobuf.Message protoBuf, org.apache.kafka.clients.consumer.ConsumerRecord<?,?> consumerRecord, boolean allowMissingKeys, boolean allowNullValues, boolean caseInsensitiveSearch)`

Method Summary

Modifier and Type	Method	Description
`boolean`	`getAllowMissingKeys()`
`boolean`	`getAllowNullValues()`
`int`	`getArraySize(String key)`
`org.apache.kafka.clients.consumer.ConsumerRecord<?,?>`	`getConsumerRecord()`
`com.google.protobuf.Descriptors.FieldDescriptor`	`getDescriptorForKey(String key)`
`com.google.protobuf.Message`	`getMessage()`
`int`	`getParallelIdx()`
`com.google.protobuf.Message`	`getProtoBuf()`
`Object`	`getValue(String key)`
`Object`	`getValue(String key, Class<?> columnClass)`
`void`	`setParallelIdx(int parallelIdx)`

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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)