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

Class PubsubMessageSchemaCoder

java.lang.Object

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

public class PubsubMessageSchemaCoder
extends java.lang.Object

Provides a SchemaCoder for PubsubMessage, including the topic and all fields of a PubSub message from server.

SchemaCoder is used so that fields can be added in the future without breaking update compatibility. Maintainers should prefer this coder when adding new features to PubsubIO.

Constructor Summary

Constructors

Constructor and Description
PubsubMessageSchemaCoder()

Method Summary

Modifier and Type	Method and Description
static SchemaCoder<PubsubMessage>	getSchemaCoder()

Methods inherited from class java.lang.Object

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

Constructor Detail

PubsubMessageSchemaCoder

public PubsubMessageSchemaCoder()

Method Detail

getSchemaCoder

public static SchemaCoder<PubsubMessage> getSchemaCoder()