Package org.apache.beam.sdk.io.gcp.pubsub

Class PubsubMessages

java.lang.Object

org.apache.beam.sdk.io.gcp.pubsub.PubsubMessages

public final class PubsubMessages
extends Object

Common util functions for converting between PubsubMessage proto and PubsubMessage.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PubsubMessages.DeserializeBytesIntoPubsubMessagePayloadOnly
static class	PubsubMessages.ParsePayloadAsPubsubMessageProto
static class	PubsubMessages.ParsePubsubMessageProtoAsPayload

Method Summary

Modifier and Type	Method	Description
static PubsubMessage	fromProto(com.google.pubsub.v1.PubsubMessage input)
static com.google.pubsub.v1.PubsubMessage	toProto(PubsubMessage input)

Methods inherited from class java.lang.Object

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

Method Details

toProto

public static com.google.pubsub.v1.PubsubMessage toProto(PubsubMessage input)

fromProto

public static PubsubMessage fromProto(com.google.pubsub.v1.PubsubMessage input)