Apache beam：複数のサブスクリプションから読み取る

Question

複数のサブスクリプションをリッスンしてBigQueryに書き込むデータフローを作成したいとします。 Googleのdocumentationによれば、複数のPCollectionオブジェクトを読んで組み合わせることができます。

しかし、PubsubIO.Readのjavadoc hereを見ると、は、Stringの1つだけを受け入れるようです。複数のサブスクリプションから読み取るには、subscriptionメソッドをチェーンする必要がありますか？

Answer 1

あなたができることは、PubSubの複数のReadを複数のサブスクリプションから読み取り、次にFlattenの結果を複数持つことです。

これは必要なのでしょうか？