Hi, Can application developers provide classes/methods to specify how to generate watermarks from sources, and how to aggregate watermarks from multiple input PCollections? Say, emit at most 1 watermark per second, or create watermarks that are 5 seconds older than the latest tuple's timestamp?
Thanks, Shen