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

Class BigQueryExportReadSchemaTransformConfiguration

java.lang.Object

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

@DefaultSchema(value=AutoValueSchema.class)
public abstract class BigQueryExportReadSchemaTransformConfiguration
extends java.lang.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 and Description
static class	BigQueryExportReadSchemaTransformConfiguration.Builder

Constructor Summary

Constructors

Constructor and Description
BigQueryExportReadSchemaTransformConfiguration()

Method Summary

Modifier and Type	Method and Description
static BigQueryExportReadSchemaTransformConfiguration.Builder	builder() Instantiates a BigQueryExportReadSchemaTransformConfiguration.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

BigQueryExportReadSchemaTransformConfiguration

public BigQueryExportReadSchemaTransformConfiguration()

Method Detail

builder

public static BigQueryExportReadSchemaTransformConfiguration.Builder builder()

Instantiates a BigQueryExportReadSchemaTransformConfiguration.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.