Hi Sidney, For the case, you can exactly write
stream. ... .window() .apply() .addSink() Operator chain will chain these operators into one so that you don't have to worry about the efficiency. Best, tison. Sidney Feiner <sidney.fei...@startapp.com> 于2020年3月22日周日 下午10:03写道： > 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 > > [image: emailsignature] > >
