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

Class PubsubMessages

java.lang.Object

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

public class PubsubMessages
extends java.lang.Object

Common util functions for converting between PubsubMessage proto and PubsubMessage.

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor and Description
PubsubMessages()

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Detail

PubsubMessages

public PubsubMessages()