@Internal @Experimental @AutoService(value=TableProvider.class) public class PubsubJsonTableProvider extends InMemoryMetaTableProvider
Modifier and Type | Class and Description |
---|---|
static class |
PubsubJsonTableProvider.PubsubIOTableConfiguration |
Constructor and Description |
---|
PubsubJsonTableProvider() |
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.
|
createTable, dropTable, getTables
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getSubProvider, getSubProviders, getTable
public java.lang.String getTableType()
TableProvider
public BeamSqlTable buildBeamSqlTable(Table tableDefintion)
TableProvider
BeamSqlTable
using the given table meta info.