Package org.apache.beam.sdk.extensions.sql.meta

Class SystemTables

java.lang.Object

org.apache.beam.sdk.extensions.sql.meta.SystemTables

public class SystemTables
extends Object

Provides BeamSqlTables that track metadata around catalogs, databases, and tables. For now, it tracks the following:

• Catalogs: Name and Type
• Databases: Name
• Tables: Name and Type

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SystemTables.CatalogsMetaTable
static class	SystemTables.DatabasesMetaTable
static class	SystemTables.TablesMetaTable

Constructor Summary

Constructors

Constructor	Description
SystemTables()

Method Summary

Modifier and Type	Method	Description
static SystemTables.CatalogsMetaTable	catalogs(CatalogManager catalogManager, boolean currentOnly)
static SystemTables.DatabasesMetaTable	databases(Catalog catalog, boolean currentOnly)
static SystemTables.TablesMetaTable	tables(Catalog catalog, String dbName)

Methods inherited from class java.lang.Object

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

Constructor Details

SystemTables

public SystemTables()

Method Details

catalogs

public static SystemTables.CatalogsMetaTable catalogs(CatalogManager catalogManager,
 boolean currentOnly)

databases

public static SystemTables.DatabasesMetaTable databases(Catalog catalog,
 boolean currentOnly)

tables

public static SystemTables.TablesMetaTable tables(Catalog catalog,
 String dbName)