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

Class SystemTables.CatalogsMetaTable

java.lang.Object

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

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

All Implemented Interfaces:

BeamSqlTable

Enclosing class:

SystemTables

public static class SystemTables.CatalogsMetaTable
extends BaseBeamTable

Constructor Summary

Constructors

Constructor	Description
CatalogsMetaTable(CatalogManager catalogManager, boolean currentOnly)

Method Summary

Modifier and Type	Method	Description
PCollection<Row>	buildIOReader(PBegin begin)	create a PCollection<Row> from source.
POutput	buildIOWriter(PCollection<Row> input)	create a IO.write() instance to write to target.
Schema	getSchema()	Get the schema info of the table.
PCollection.IsBounded	isBounded()	Whether this table is bounded (known to be finite) or unbounded (may or may not be finite).

Methods inherited from class org.apache.beam.sdk.extensions.sql.meta.BaseBeamTable

buildIOReader, constructFilter, getTableStatistics, supportsProjects

Methods inherited from class java.lang.Object

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

Constructor Details

CatalogsMetaTable

public CatalogsMetaTable(CatalogManager catalogManager,
 boolean currentOnly)

Method Details

buildIOReader

public PCollection<Row> buildIOReader(PBegin begin)

Description copied from interface: BeamSqlTable

create a PCollection<Row> from source.

buildIOWriter

public POutput buildIOWriter(PCollection<Row> input)

Description copied from interface: BeamSqlTable

create a IO.write() instance to write to target.

isBounded

public PCollection.IsBounded isBounded()

Description copied from interface: BeamSqlTable

Whether this table is bounded (known to be finite) or unbounded (may or may not be finite).

getSchema

public Schema getSchema()

Description copied from interface: BeamSqlTable

Get the schema info of the table.