Package 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(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	Description
BigQueryTableProvider()

Method Summary

Modifier and Type	Method	Description
BeamSqlTable	buildBeamSqlTable(Table table)	Build a BeamSqlTable using the given table meta info.
protected static org.apache.beam.sdk.io.gcp.bigquery.BigQueryUtils.ConversionOptions	getConversionOptions(com.fasterxml.jackson.databind.node.ObjectNode 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, supportsPartitioning

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 org.apache.beam.sdk.io.gcp.bigquery.BigQueryUtils.ConversionOptions getConversionOptions(com.fasterxml.jackson.databind.node.ObjectNode properties)