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

Class PubsubMessageSchemaCoder

java.lang.Object

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

public class PubsubMessageSchemaCoder
extends 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	Description
PubsubMessageSchemaCoder()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

PubsubMessageSchemaCoder

public PubsubMessageSchemaCoder()

Method Details

getSchemaCoder

public static SchemaCoder<PubsubMessage> getSchemaCoder()