Луч Apache: чтение из нескольких подписок

Я хочу создать поток данных, который прослушивает несколько подписок и записывает в BigQuery. Согласно документации Google, я могу читать несколько PCollection объектов и объединять их вместе.

Однако, глядя на PubsubIO.Read javadoc здесь, кажется, subscription метод принимает только один String. Итак, нужно ли нам связывать subscription методы, чтобы читать из нескольких подписок?


person Darshan Mehta    schedule 06.11.2017    source источник


Ответы (1)


Вы можете использовать несколько Read из PubSub, каждый из которых читает из одной подписки, а затем Flatten их результаты.

Это сделало бы то, что вам нужно?

person Pablo    schedule 06.11.2017
comment
Согласовано - создайте несколько подписок. - person Yuri Grinshteyn; 07.11.2017