У меня есть конвейер потока данных, который читает из таблицы BigQuery. Однако при чтении данных нет другого выхода, кроме как прочитать все записи с read (SerializableFunction) или readTableRows ( ) методы. Мне было интересно, при использовании этих методов, есть ли возможность предоставить проекцию в виде столбца (аналогично HBaseIO Scan addColumn () filter).
Я знаю, что есть возможность выполнить запрос при загрузке данных из BigQuery (используя readTableRows (). fromQuery ()), но мне интересно, есть ли там - это аналогичный вариант для создания проекции, подобный возможному в HBaseIO.
