2

我有一个从 BigQuery 表中读取数据的数据流管道。但是,在读取数据时,除了使用read(SerializableFunction)readTableRows()方法读取所有记录之外别无选择。我想知道,在使用这些方法时,是否有提供类似列的投影的选项(类似于 HBaseIO Scan addColumn()过滤器)。

我知道从 BigQuery 加载数据时可以选择执行查询(使用readTableRows().fromQuery()),但我想知道是否有类似的选项可以在 HBaseIO 中进行投影。

4

1 回答 1

3

截至目前, fromQuery() 是唯一的选择,但将来可能会改变。

于 2018-02-22T21:21:44.137 回答