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

提问者：小点点

我正在尝试读取数据流上的BigQuery数据，我想将其读取为通用记录类型而不是TableRow。有没有办法直接加载为通用记录而无需从TableRow转换为通用记录？

共1个答案

匿名用户

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

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