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

Question

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

Answer 1

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

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