При чтении из BigQuery Dataflow на самом деле просто вызывает API экспорта BigQuery и выдает таблицу / запрос в GCS в виде набора защищенных файлов Avro. Как только файлы начинают поступать в GCS, работники потока данных начинают читать их параллельно. Как работа распределяется, т.е. какой работник читает, какой осколок / записи абстрагируется от вас и обрабатывается / управляется самой службой потока данных.