Я хочу создать поток данных, который прослушивает несколько подписок и записывает в BigQuery. Согласно документации Google, я могу читать несколько PCollection
объектов и объединять их вместе.
Однако, глядя на PubsubIO.Read
javadoc здесь, кажется, subscription
метод принимает только один String
. Итак, нужно ли нам связывать subscription
методы, чтобы читать из нескольких подписок?