【发布时间】:2016-02-10 20:27:42
【问题描述】:
使用数据流从 BigQuery 表中读取时,我得到了 null 元素,如下所示
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() 提取的单元格都是空的。
我注意到已经有人问过here 的类似问题,但答案对我来说有点不清楚......我已经尝试将库版本更新为 1.3.0 但似乎问题仍未解决。 (由于一些依赖问题,目前去1.4.0版本有点痛苦……)
(作为一个堆栈溢出的新手,我没有足够的积分来发布cmets,所以必须在这里再次询问......)
【问题讨论】:
-
我已经用stackoverflow.com/a/35326342/278042 更新了您链接到的问题。
-
您还在遇到这个问题吗?
-
@Nicholas 嘿,使用
get("fieldname")对我有用。而从来没有getF()
标签: google-bigquery google-cloud-dataflow