Details
-
Improvement
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
1.12.2, 1.13.0
Description
Hi all,
I belive the scala code in the "Writing a Periodic WatermarkGenerator" and "Writing a Punctuated WatermarkGenerator" sections (Event Time -> Generating Watermark) is outdated/wrong.
And it's also missing in the previous section "Writing WatermarkGenerators".
It uses undefined arguments (output) – the onEvent and onPeriodicEmit methods have the wrong signatures.
If it's alright I can put up a PR with the scala code on how to extend WatermarkGenerator class and some comment.
Also sorry if I misplaced this Issue, feel free to improve/correct
Giack
Attachments
Issue Links
- links to