public abstract static class BigQueryIO.TypedRead<T>
extends <any>
BigQueryIO.read(SerializableFunction)
.Modifier and Type | Class and Description |
---|---|
static class |
BigQueryIO.TypedRead.Method
Determines the method used to read data from BigQuery.
|
static class |
BigQueryIO.TypedRead.QueryPriority
An enumeration type for the priority of a query.
|
Constructor and Description |
---|
TypedRead() |
public void validate(PipelineOptions options)
public PCollection<T> expand(PBegin input)
public void populateDisplayData(DisplayData.Builder builder)
@Nullable public ValueProvider<TableReference> getTableProvider()
@Nullable public TableReference getTable()
public BigQueryIO.TypedRead<T> withCoder(Coder<T> coder)
Coder
for the result of the parse function. This may be required if a coder
can not be inferred automatically.public BigQueryIO.TypedRead<T> withKmsKey(java.lang.String kmsKey)
@Experimental(value=SCHEMAS) public BigQueryIO.TypedRead<T> withBeamRowConverters(org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.TypedRead.ToBeamRowFunction<T> toRowFn, org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.TypedRead.FromBeamRowFunction<T> fromRowFn)
public BigQueryIO.TypedRead<T> from(java.lang.String tableSpec)
public BigQueryIO.TypedRead<T> from(ValueProvider<java.lang.String> tableSpec)
public BigQueryIO.TypedRead<T> fromQuery(java.lang.String query)
public BigQueryIO.TypedRead<T> fromQuery(ValueProvider<java.lang.String> query)
public BigQueryIO.TypedRead<T> from(TableReference table)
public BigQueryIO.TypedRead<T> withoutValidation()
public BigQueryIO.TypedRead<T> withoutResultFlattening()
public BigQueryIO.TypedRead<T> usingStandardSql()
public BigQueryIO.TypedRead<T> withQueryPriority(BigQueryIO.TypedRead.QueryPriority priority)
public BigQueryIO.TypedRead<T> withQueryLocation(java.lang.String location)
@Experimental(value=SOURCE_SINK) public BigQueryIO.TypedRead<T> withMethod(BigQueryIO.TypedRead.Method method)
@Experimental(value=SOURCE_SINK) public BigQueryIO.TypedRead<T> withReadOptions(com.google.cloud.bigquery.storage.v1beta1.ReadOptions.TableReadOptions readOptions)
@Experimental(value=SOURCE_SINK) public BigQueryIO.TypedRead<T> withTemplateCompatibility()