public static class ExternalWrite.ParsePubsubMessageProtoAsPayloadFromWindowedValue extends java.lang.Object implements org.apache.beam.sdk.transforms.SerializableFunction<org.apache.beam.sdk.values.ValueInSingleWindow<byte[]>,PubsubMessage>
Constructor and Description |
---|
ParsePubsubMessageProtoAsPayloadFromWindowedValue() |
Modifier and Type | Method and Description |
---|---|
PubsubMessage |
apply(org.apache.beam.sdk.values.ValueInSingleWindow<byte[]> input) |
public ParsePubsubMessageProtoAsPayloadFromWindowedValue()
public PubsubMessage apply(org.apache.beam.sdk.values.ValueInSingleWindow<byte[]> input)
apply
in interface org.apache.beam.sdk.transforms.ProcessFunction<org.apache.beam.sdk.values.ValueInSingleWindow<byte[]>,PubsubMessage>
apply
in interface org.apache.beam.sdk.transforms.SerializableFunction<org.apache.beam.sdk.values.ValueInSingleWindow<byte[]>,PubsubMessage>