使用数据流从 BQ 读取时为 null TableCell

Question

我使用数据流从 BigQuery table 读取时得到空元素，如下所示

private static class ParseBQInput extends DoFn<TableRow, KV<String, MyClass> > {
    @Override
    public void processElement(ProcessContext c) throws Exception {
        TableRow row = c.element();
        List<TableCell> cells = row.getF();
        if (cells == null) {
            throw new RuntimeException("Get null cells");
        }

        // Other operation
    }
}

我用row.getF()提取的单元格是空的，不管我读的是哪个table。我注意到已经有人问过类似的问题但答案对我来说有点不清楚......我已经尝试将库版本更新到 1.3.0 但似乎问题仍未解决。（由于一些依赖问题，目前转到1.4.0版本有点痛苦。。。）

（作为stack overflow的新手，我没有足够的积分来评论post，所以不得不在这里再次提问...）

Answer 1

如更新后的中所述，getF() 将不受新版本支持。请使用 get("fieldname")。感谢您的耐心等待。

使用数据流从 BQ 读取时为 null TableCell

null TableCell when reading from BQ using dataflow

google-bigquery

google-cloud-dataflow