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 java.math.BigInteger	getNumRows(BigQueryOptions options, TableReference tableRef) It returns the number of rows for a given table.
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.

getNumRows

@Nullable
public static java.math.BigInteger getNumRows(BigQueryOptions options,
                                                        TableReference tableRef)
                                                 throws java.lang.InterruptedException,
                                                        java.io.IOException

It returns the number of rows for a given table.

Returns:

The number of rows in the table or null if it cannot get any estimate.

Throws:

java.lang.InterruptedException

java.io.IOException