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

@AutoService(value=TableProvider.class)
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.
protected static BigQueryUtils.ConversionOptions	getConversionOptions(com.alibaba.fastjson.JSONObject properties)
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

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.

getConversionOptions

protected static BigQueryUtils.ConversionOptions getConversionOptions(com.alibaba.fastjson.JSONObject properties)