org.apache.beam.sdk.io.gcp.bigquery

Class BigQueryHelpers

java.lang.Object

org.apache.beam.sdk.io.gcp.bigquery.BigQueryHelpers

public class BigQueryHelpers
extends java.lang.Object

A set of helper functions and classes used by BigQueryIO.

Constructor Summary

Constructors

Constructor and Description
BigQueryHelpers()

Method Summary

Modifier and Type	Method and Description
static TableReference	parseTableSpec(java.lang.String tableSpec) Parse a table specification in the form "[project_id]:[dataset_id].[table_id]" or "[dataset_id].[table_id]".
static java.lang.String	stripPartitionDecorator(java.lang.String tableSpec) Strip off any partition decorator information from a tablespec.
static java.lang.String	toTableSpec(TableReference ref) Returns a canonical string representation of the TableReference.
static java.lang.String	toTableSpec(com.google.cloud.bigquery.storage.v1beta1.TableReferenceProto.TableReference ref) Returns a canonical string representation of a TableReferenceProto.TableReference.

Methods inherited from class java.lang.Object

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

Constructor Detail

BigQueryHelpers

public BigQueryHelpers()

Method Detail

toTableSpec

public static java.lang.String toTableSpec(TableReference ref)

Returns a canonical string representation of the TableReference.

toTableSpec

public static java.lang.String toTableSpec(com.google.cloud.bigquery.storage.v1beta1.TableReferenceProto.TableReference ref)

Returns a canonical string representation of a TableReferenceProto.TableReference.

parseTableSpec

public static TableReference parseTableSpec(java.lang.String tableSpec)

Parse a table specification in the form "[project_id]:[dataset_id].[table_id]" or "[dataset_id].[table_id]".

If the project id is omitted, the default project id is used.

stripPartitionDecorator

public static java.lang.String stripPartitionDecorator(java.lang.String tableSpec)

Strip off any partition decorator information from a tablespec.