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

Class BigQueryDynamicReadDescriptor

java.lang.Object

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

All Implemented Interfaces:

Serializable

@DefaultSchema(AutoValueSchema.class)
public abstract class BigQueryDynamicReadDescriptor
extends Object
implements Serializable

Represents a BigQuery source description used for dynamic read.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
BigQueryDynamicReadDescriptor()

Method Summary

Modifier and Type	Method	Description
static BigQueryDynamicReadDescriptor	create(@Nullable String query, @Nullable String table, @Nullable Boolean flattenResults, @Nullable Boolean useLegacySql, @Nullable List<String> selectedFields, @Nullable String rowRestriction)
static BigQueryDynamicReadDescriptor	query(String query, Boolean flattenResults, Boolean useLegacySql)
static BigQueryDynamicReadDescriptor	table(String table, @Nullable List<String> selectedFields, @Nullable String rowRestriction)

Methods inherited from class java.lang.Object

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

Constructor Details

BigQueryDynamicReadDescriptor

public BigQueryDynamicReadDescriptor()

Method Details

create

@SchemaCreate
public static BigQueryDynamicReadDescriptor create(@Nullable String query,
 @Nullable String table,
 @Nullable Boolean flattenResults,
 @Nullable Boolean useLegacySql,
 @Nullable List<String> selectedFields,
 @Nullable String rowRestriction)

query

public static BigQueryDynamicReadDescriptor query(String query,
 Boolean flattenResults,
 Boolean useLegacySql)

table

public static BigQueryDynamicReadDescriptor table(String table,
 @Nullable List<String> selectedFields,
 @Nullable String rowRestriction)