public class ProtoToBytes<T extends com.google.protobuf.Message>
extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<T>,org.apache.beam.sdk.values.PCollection<byte[]>>
Constructor and Description |
---|
ProtoToBytes() |
Modifier and Type | Method and Description |
---|---|
org.apache.beam.sdk.values.PCollection<byte[]> |
expand(org.apache.beam.sdk.values.PCollection<T> input) |
addAnnotation, compose, compose, getAdditionalInputs, getAnnotations, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, populateDisplayData, setResourceHints, toString, validate, validate
public org.apache.beam.sdk.values.PCollection<byte[]> expand(org.apache.beam.sdk.values.PCollection<T> input)
expand
in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<T extends com.google.protobuf.Message>,org.apache.beam.sdk.values.PCollection<byte[]>>