google-bigquery - Apache Beam - 将大查询读取为通用记录（Avro 格式）

Question

我正在尝试读取 Dataflow 上的 BigQuery 数据，我想将其读取为通用记录类型而不是 TableRows。有什么方法可以直接加载为通用记录而不需要从 TableRows 转换为通用记录？

标签： google-bigqueryapache-beamdataflow

Answer 1

SchemaAndRecord已经包含GenericRecord. 那么你能做这样的事情吗？

BigQueryIO.read(
        (SerializableFunction<SchemaAndRecord, GenericRecord>) input -> input.getRecord());