带有 pubsub 源的数据流水印
dataflow watermark with pubsub source
在 apache beam 文档中，提到 pcollections 的水印由源确定。将 pubsub 视为源，pubsub 使用什么逻辑来导出水印。有关此的任何文档，以便更好地理解。
要定义水印，我们需要关注延迟数据方面。
“请参阅下面的 link 以了解 pubsub 逻辑。”
What is the watermark heuristic for PubsubIO running on GCD?
在 apache beam 文档中，提到 pcollections 的水印由源确定。将 pubsub 视为源，pubsub 使用什么逻辑来导出水印。有关此的任何文档，以便更好地理解。
要定义水印，我们需要关注延迟数据方面。 “请参阅下面的 link 以了解 pubsub 逻辑。”
What is the watermark heuristic for PubsubIO running on GCD?