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

All Implemented Interfaces:

TableProvider

@Internal
 @Experimental
public class PubsubJsonTableProvider
extends InMemoryMetaTableProvider

TableProvider for PubsubIOJsonTable which wraps PubsubIO for consumption by Beam SQL.

Constructor Summary

Constructors

Constructor and Description
PubsubJsonTableProvider()

Method Summary

Modifier and Type	Method and Description
BeamSqlTable	buildBeamSqlTable(Table tableDefintion) Build a BeamSqlTable using the given table meta info.
java.lang.String	getTableType() Gets the table type this provider handles.

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

Constructor Detail

PubsubJsonTableProvider

public PubsubJsonTableProvider()

Method Detail

getTableType

public java.lang.String getTableType()

Description copied from interface: TableProvider

Gets the table type this provider handles.

buildBeamSqlTable

public BeamSqlTable buildBeamSqlTable(Table tableDefintion)

Description copied from interface: TableProvider

Build a BeamSqlTable using the given table meta info.