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

Class PubsubTableProvider

java.lang.Object

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

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

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

All Implemented Interfaces:

java.io.Serializable, TableProvider

@Internal
 @Experimental
 @AutoService(value=TableProvider.class)
public class PubsubTableProvider
extends SchemaIOTableProviderWrapper

TableProvider for PubsubIO for consumption by Beam SQL.

Passes the PubsubSchemaIOProvider to the generalized table provider wrapper, SchemaIOTableProviderWrapper, for Pubsub specific behavior with payload in json/avro format.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
PubsubTableProvider()

Method Summary

Modifier and Type	Method and Description
SchemaIOProvider	getSchemaIOProvider()
java.lang.String	getTableType() Gets the table type this provider handles.

Methods inherited from class org.apache.beam.sdk.extensions.sql.meta.provider.SchemaIOTableProviderWrapper

buildBeamSqlTable, getTableStatistics

Methods inherited from class org.apache.beam.sdk.extensions.sql.meta.provider.InMemoryMetaTableProvider

createTable, dropTable, getTables

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.beam.sdk.extensions.sql.meta.provider.TableProvider

getSubProvider, getSubProviders, getTable

Constructor Detail

PubsubTableProvider

public PubsubTableProvider()

Method Detail

getSchemaIOProvider

public SchemaIOProvider getSchemaIOProvider()

Specified by:

getSchemaIOProvider in class SchemaIOTableProviderWrapper

getTableType

public java.lang.String getTableType()

Description copied from interface: TableProvider

Gets the table type this provider handles.

Specified by:

getTableType in interface TableProvider

Overrides:

getTableType in class SchemaIOTableProviderWrapper