在数据流中将BigQuery TableRow转换为GenericRecords

提问者：小点点

波束中是否有任何功能可用于将bigquery表转换为avro通用记录？

我试图为类似的东西找到任何参考，但到目前为止我还没有运气。

共1个答案

匿名用户

你可能想看看https://beam.apache.org/releases/javadoc/2.40.0/org/apache/beam/sdk/io/gcp/bigquery/BigQueryUtils.html（TableRow-

不过，您仍然需要一个模式。