在Beam（DataFlow2.0.0）中，我正在阅读一个PubSub主题，然后尝试根据该主题的消息从Begtable中获取几行。我找不到通过BeamDocumentation基于PubSub消息扫描Boogtable的方法。我试图编写pardo功能并将其管道输送到梁管道中，但徒劳无功。BigTableIO提供了一种阅读的选项，但它不在管道之外，并且不确定它会像我的用例一样蒸蒸日上。任何人都可以让我知道这是否可以像流媒体pubsub一样可行，并根据消息内容读取Boogtable。P.S：我在Beam2.0中使用JavaAPI。PCollectionkeyLines=pipeline.apply