I originally posted to Stack Overflow because I was trying to figure out he to do this in Flink.
Wondering how to implement something of the sort: (1) *write up: * https://drive.google.com/file/d/0Bw69DO1tid2_SzVVendtUV9WMVdIUXptQ1hHSl9KNjAyMTBn/view?usp=drivesdk (2) *original post: * https://stackoverflow.com/questions/50949083/custom-watermarks-with-apache-flink -- Wyatt J. Frelot
