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

Class BigQueryExportReadSchemaTransformConfiguration

java.lang.Object

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

@DefaultSchema(AutoValueSchema.class)
public abstract class BigQueryExportReadSchemaTransformConfiguration
extends Object

Configuration for reading from BigQuery.

This class is meant to be used with BigQueryExportReadSchemaTransformProvider.

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	Description
static class	BigQueryExportReadSchemaTransformConfiguration.Builder

Constructor Summary

Constructors

Constructor	Description
BigQueryExportReadSchemaTransformConfiguration()

Method Summary

Modifier and Type	Method	Description
static BigQueryExportReadSchemaTransformConfiguration.Builder	builder()	Instantiates a BigQueryExportReadSchemaTransformConfiguration.Builder.
abstract String	getQuery()	Configures the BigQuery read job with the SQL query.
abstract String	getQueryLocation()	BigQuery geographic location where the query job will be executed.
abstract String	getTableSpec()	Specifies a table for a BigQuery read job.
abstract 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 Details

BigQueryExportReadSchemaTransformConfiguration

public BigQueryExportReadSchemaTransformConfiguration()

Method Details

builder

public static BigQueryExportReadSchemaTransformConfiguration.Builder builder()

Instantiates a BigQueryExportReadSchemaTransformConfiguration.Builder.

getQuery

@Nullable
public abstract String getQuery()

Configures the BigQuery read job with the SQL query.

getTableSpec

@Nullable
public abstract 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 String getQueryLocation()

BigQuery geographic location where the query job will be executed.

getUseStandardSql

@Nullable
public abstract Boolean getUseStandardSql()

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