Package io.deephaven.kafka.ingest.protobuf

Class ProtobufDescriptorParser

java.lang.Object

io.deephaven.kafka.ingest.protobuf.ProtobufDescriptorParser

All Implemented Interfaces:

ProtobufParser

public class ProtobufDescriptorParser
extends Object
implements ProtobufParser

Constructor Summary

Constructors

Constructor	Description
ProtobufDescriptorParser(String protoDescriptor)

Method Summary

Modifier and Type	Method	Description
com.google.protobuf.Message	parseFrom(byte[] bytes)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.kafka.ingest.protobuf.ProtobufParser

getParallelValueField, hasParallelValueField, withParallelValueField

Constructor Details

ProtobufDescriptorParser

public ProtobufDescriptorParser(String protoDescriptor)

Method Details

parseFrom

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

Specified by:

parseFrom in interface ProtobufParser

Throws:

com.google.protobuf.InvalidProtocolBufferException