Hey, I wanted to know if it's possible to define a SinkFunction as a WindowFunction as well. For example, I would like the sink to be invoked every 5 minute or once 500 events reached the sink. Is there a way to do this inside the sink implementation? Or do I have to create the windows prior in the pipeline? Because if I have multiple sinks that that only for one of them I need a Window, the second solution might be problematic.
Thanks :) Sidney Feiner / Data Platform Developer M: +972.528197720 / Skype: sidney.feiner.startapp [emailsignature]
