org.apache.beam.sdk.extensions.sql.meta.provider.pubsub

Class PubsubJsonTableProvider.PubsubIOTableConfiguration

java.lang.Object

org.apache.beam.sdk.extensions.sql.meta.provider.pubsub.PubsubJsonTableProvider.PubsubIOTableConfiguration

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

PubsubJsonTableProvider

public abstract static class PubsubJsonTableProvider.PubsubIOTableConfiguration
extends java.lang.Object
implements java.io.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
PubsubIOTableConfiguration()

Method Summary

Modifier and Type	Method and Description
abstract Schema	getSchema() Table schema, describes Pubsub message schema.
boolean	useDlq()
boolean	useTimestampAttribute()

Methods inherited from class java.lang.Object

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

Constructor Detail

PubsubIOTableConfiguration

public PubsubIOTableConfiguration()

Method Detail

useDlq

public boolean useDlq()

useTimestampAttribute

public boolean useTimestampAttribute()

getSchema

public abstract Schema getSchema()

Table schema, describes Pubsub message schema.

If getUseFlatSchema() is not set, schema must contain exactly fields 'event_timestamp', 'attributes, and 'payload'. Else, it must contain just 'event_timestamp'. See for details.