我有一个从BigQuery表读取的Dataflow管道 . 但是，在读取数据时，除了使用read(SerializableFunction)或readTableRows()方法读取所有记录之外别无选择 . 我想知道，在使用这些方法时，是否可以选择提供类似列的投影（类似于HBaseIO Scan addColumn()过滤器） .
我知道在从BigQuery加载数据时可以选择执行查询（使用readTableRows().fromQuery()），但我想知道是否有类似的选项可以在HBaseIO中进行投影 .
1 回答
截至目前，fromQuery（）是唯一的选择，但这可能会在未来发生变化 .