pe: sidney.feiner.startapp
>
> [image: emailsignature]
>
> --
> *From:* tison
> *Sent:* Sunday, March 22, 2020 4:19 PM
> *To:* Sidney Feiner
> *Cc:* user@flink.apache.org
> *Subject:* Re: Windows on SinkFunctions
>
> Hi Sidney,
>
> For the case, you
4:19 PM
To: Sidney Feiner
Cc: user@flink.apache.org
Subject: Re: Windows on SinkFunctions
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
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 于2020年3月22日周日 下午10:03写道：
> Hey,
> I wanted to know if it's
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
