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
 @AutoService(value=TableProvider.class)
public class PubsubJsonTableProvider
extends InMemoryMetaTableProvider

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PubsubJsonTableProvider.PubsubIOTableConfiguration

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

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

getSubProvider, getSubProviders, getTable

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.