Мы отправляем сообщения для нескольких таблиц pub / sub к одной и той же подписке.Атрибут pub / sub определяет, в какие таблицы он пишет.Некоторые таблицы являются агрегатными таблицами, которые выиграют от просто усечения / перезагрузки таблицы.
Когда я пытаюсь установить расположение записи для усечения, я получаю сообщение об ошибке
Caused by: java.lang.IllegalArgumentException: WriteDisposition.WRITE_TRUNCATE is not supported for an unbounded PCollection.
Есть ли способуничтожить / перезагрузить таблицы BigQuery при поступлении определенных сообщений из pub / sub?