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

Class PubsubJsonTableProvider

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.PubsubJsonTableProvider

All Implemented Interfaces:

java.io.Serializable, TableProvider

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

TableProvider for PubsubIO for consumption by Beam SQL.

Passes the PubsubSchemaIOProvider to the generalized table provider wrapper, SchemaIOTableProviderWrapper, for Pubsub specific behavior.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
PubsubJsonTableProvider()

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

PubsubJsonTableProvider

public PubsubJsonTableProvider()

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