![]() |
Read data from BigQuery.
tfx.extensions.google_cloud_big_query.utils.ReadFromBigQuery(
pipeline: beam.Pipeline,
query: Text
) -> beam.pvalue.PCollection
Args | |
---|---|
pipeline
|
Beam pipeline. |
query
|
A BigQuery sql string. |
Returns | |
---|---|
PCollection of dict. |