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

Class ProtoBeamConverter

java.lang.Object

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

public class ProtoBeamConverter
extends java.lang.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 org.apache.beam.sdk.transforms.SerializableFunction<org.apache.beam.sdk.values.Row,com.google.protobuf.Message>	toProto(com.google.protobuf.Descriptors.Descriptor descriptor)	Returns a conversion method from Beam Row to Protobuf Message.
static org.apache.beam.sdk.transforms.SerializableFunction<com.google.protobuf.Message,org.apache.beam.sdk.values.Row>	toRow(org.apache.beam.sdk.schemas.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 Detail

ProtoBeamConverter

public ProtoBeamConverter()

Method Detail

toProto

public static org.apache.beam.sdk.transforms.SerializableFunction<org.apache.beam.sdk.values.Row,com.google.protobuf.Message> toProto(com.google.protobuf.Descriptors.Descriptor descriptor)

Returns a conversion method from Beam Row to Protobuf Message.

toRow

public static org.apache.beam.sdk.transforms.SerializableFunction<com.google.protobuf.Message,org.apache.beam.sdk.values.Row> toRow(org.apache.beam.sdk.schemas.Schema schema)

Returns a conversion method from Protobuf Message to Beam Row.