Package io.deephaven.kafka.ingest.protobuf

Interface ProtobufParser

All Known Implementing Classes:
ProtobufDescriptorParser, ProtobufFunctionalParser
public interface ProtobufParser

  • Method Details

    • parseFrom

      com.google.protobuf.Message parseFrom(byte[] bytes) throws com.google.protobuf.InvalidProtocolBufferException
      Throws:
      com.google.protobuf.InvalidProtocolBufferException

    • hasParallelValueField

      default boolean hasParallelValueField()

    • withParallelValueField

      default void withParallelValueField(String parallelField)

    • getParallelValueField

      default String getParallelValueField()