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

Class BigQueryDirectReadSchemaTransformProvider.BigQueryDirectReadSchemaTransformConfiguration

java.lang.Object

org.apache.beam.sdk.io.gcp.bigquery.providers.BigQueryDirectReadSchemaTransformProvider.BigQueryDirectReadSchemaTransformConfiguration

Enclosing class:

BigQueryDirectReadSchemaTransformProvider

@DefaultSchema(value=AutoValueSchema.class)
public abstract static class BigQueryDirectReadSchemaTransformProvider.BigQueryDirectReadSchemaTransformConfiguration
extends java.lang.Object

Configuration for reading from BigQuery with Storage Read API.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BigQueryDirectReadSchemaTransformProvider.BigQueryDirectReadSchemaTransformConfiguration.Builder

Constructor Summary

Constructors

Constructor and Description
BigQueryDirectReadSchemaTransformConfiguration()

Method Summary

Modifier and Type	Method and Description
static BigQueryDirectReadSchemaTransformProvider.BigQueryDirectReadSchemaTransformConfiguration.Builder	builder() Instantiates a BigQueryDirectReadSchemaTransformProvider.BigQueryDirectReadSchemaTransformConfiguration.Builder instance.
abstract java.lang.String	getQuery()
abstract java.lang.String	getRowRestriction()
abstract java.util.List<java.lang.String>	getSelectedFields()
abstract java.lang.String	getTableSpec()
void	validate()

Methods inherited from class java.lang.Object

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

Constructor Detail

BigQueryDirectReadSchemaTransformConfiguration

public BigQueryDirectReadSchemaTransformConfiguration()

Method Detail

validate

public void validate()

builder

public static BigQueryDirectReadSchemaTransformProvider.BigQueryDirectReadSchemaTransformConfiguration.Builder builder()

Instantiates a BigQueryDirectReadSchemaTransformProvider.BigQueryDirectReadSchemaTransformConfiguration.Builder instance.

getQuery

@SchemaFieldDescription(value="The SQL query to be executed to read from the BigQuery table.")
 @Nullable
public abstract java.lang.String getQuery()

getTableSpec

@SchemaFieldDescription(value="The fully-qualified name of the BigQuery table to read from. Format: [${PROJECT}:]${DATASET}.${TABLE}")
 @Nullable
public abstract java.lang.String getTableSpec()

getRowRestriction

@SchemaFieldDescription(value="Read only rows that match this filter, which must be compatible with Google standard SQL. This is not supported when reading via query.")
 @Nullable
public abstract java.lang.String getRowRestriction()

getSelectedFields

@SchemaFieldDescription(value="Read only the specified fields (columns) from a BigQuery table. Fields may not be returned in the order specified. If no value is specified, then all fields are returned. Example: \"col1, col2, col3\"")
 @Nullable
public abstract java.util.List<java.lang.String> getSelectedFields()