我有一个从BigQuery表中读取数据的数据流管道。但是,在读取数据时,除了使用read(SerializableFunction)或readTableRows()方法读取所有记录之外,没有其他选择。我想知道,在使用这些方法时,是否有提供列状投影的选项(类似于HBaseIO Scan addColumn()过滤器)。
我知道从BigQuery加载数据(使用readTableRows().fromQuery())时可以选择执行查询,但我想知道是否有类似的选项来像在HBaseIO中一样执行投影。
发布于 2018-02-23 05:21:44
到目前为止,fromQuery()是唯一的选择,但这种情况将来可能会改变。
https://stackoverflow.com/questions/48929701
复制相似问题