org.apache.beam.sdk.extensions.sql.meta.provider.bigquery

Class BigQueryTableProvider

java.lang.Object

org.apache.beam.sdk.extensions.sql.meta.provider.InMemoryMetaTableProvider

org.apache.beam.sdk.extensions.sql.meta.provider.bigquery.BigQueryTableProvider

All Implemented Interfaces:

TableProvider

public class BigQueryTableProvider
extends InMemoryMetaTableProvider

BigQuery table provider.

A sample of text table is:

 CREATE TABLE ORDERS(
   ID INT COMMENT 'this is the primary key',
   NAME VARCHAR(127) COMMENT 'this is the name'
 )
 TYPE 'bigquery'
 COMMENT 'this is the table orders'
 LOCATION '[PROJECT_ID]:[DATASET].[TABLE]'
 

Constructor Summary

Constructors

Constructor and Description
BigQueryTableProvider()

Method Summary

Modifier and Type	Method and Description
BeamSqlTable	buildBeamSqlTable(Table table) 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

BigQueryTableProvider

public BigQueryTableProvider()

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 table)

Description copied from interface: TableProvider

Build a BeamSqlTable using the given table meta info.