Добавьте в ваш поток данных шаг, который вызывает Google API Tables.get ИЛИ выполните этот запрос до и после потока (оба одинаково хороши).
select row_count, table_id from `dataset.__TABLES__` where table_id = 'audit'
В качестве примеразапрос возвращает это