Package org.apache.beam.sdk.extensions.protobuf

Class ProtoBeamConverter

java.lang.Object

org.apache.beam.sdk.extensions.protobuf.ProtoBeamConverter

public class ProtoBeamConverter
extends Object

Provides converts between Protobuf Message and Beam Row.

Read https://s.apache.org/beam-protobuf

Constructor Summary

Constructors

Constructor	Description
ProtoBeamConverter()

Method Summary

Modifier and Type	Method	Description
static SerializableFunction<Row,Message>	toProto(Descriptors.Descriptor descriptor)	Returns a conversion method from Beam Row to Protobuf Message.
static SerializableFunction<Message,Row>	toRow(Schema schema)	Returns a conversion method from Protobuf Message to Beam Row.

Methods inherited from class java.lang.Object

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

Constructor Details

ProtoBeamConverter

public ProtoBeamConverter()

Method Details

toProto

public static SerializableFunction<Row,Message> toProto(Descriptors.Descriptor descriptor)

Returns a conversion method from Beam Row to Protobuf Message.

toRow

public static SerializableFunction<Message,Row> toRow(Schema schema)

Returns a conversion method from Protobuf Message to Beam Row.