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

Class BigQuerySchemaTransformReadConfiguration

java.lang.Object

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

@DefaultSchema(value=AutoValueSchema.class)
public abstract class BigQuerySchemaTransformReadConfiguration
extends java.lang.Object

Configuration for reading from BigQuery.

This class is meant to be used with BigQuerySchemaTransformReadProvider.

Internal only: This class is actively being worked on, and it will likely change. We provide no backwards compatibility guarantees, and it should not be implemented outside the Beam repository.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BigQuerySchemaTransformReadConfiguration.Builder

Constructor Summary

Constructors

Constructor and Description
BigQuerySchemaTransformReadConfiguration()

Method Summary

Modifier and Type	Method and Description
static BigQuerySchemaTransformReadConfiguration.Builder	builder() Instantiates a BigQuerySchemaTransformReadConfiguration.Builder.
abstract java.lang.String	getQuery() Configures the BigQuery read job with the SQL query.
abstract java.lang.String	getQueryLocation() BigQuery geographic location where the query job will be executed.
abstract java.lang.String	getTableSpec() Specifies a table for a BigQuery read job.
abstract java.lang.Boolean	getUseStandardSql() Enables BigQuery's Standard SQL dialect when reading from a query.

Methods inherited from class java.lang.Object

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

Constructor Detail

BigQuerySchemaTransformReadConfiguration

public BigQuerySchemaTransformReadConfiguration()

Method Detail

builder

public static BigQuerySchemaTransformReadConfiguration.Builder builder()

Instantiates a BigQuerySchemaTransformReadConfiguration.Builder.

getQuery

@Nullable
public abstract java.lang.String getQuery()

Configures the BigQuery read job with the SQL query.

getTableSpec

@Nullable
public abstract java.lang.String getTableSpec()

Specifies a table for a BigQuery read job. See BigQueryIO.TypedRead.from(String) for more details on the expected format.

getQueryLocation

@Nullable
public abstract java.lang.String getQueryLocation()

BigQuery geographic location where the query job will be executed.

getUseStandardSql

@Nullable
public abstract java.lang.Boolean getUseStandardSql()

Enables BigQuery's Standard SQL dialect when reading from a query.