I tried。 But the MyProcessWindowFunction still not tigged when there's no
event in the window
Any insight on this?
source.assignTimestampsAndWatermarks(new AssignerWithPeriodicWatermarks<Map>() {
@Override
public Watermark getCurrentWatermark() {
return new Watermark(System.currentTimeMillis() - 10000);
}
@Override
public long extractTimestamp(Map map, long l) {
return System.currentTimeMillis();
}
}).windowAll(TumblingEventTimeWindows.of(Time.seconds(10))).process(new
MyProcessWindowFunction());
[email protected]
From: Puneet Kinra
Date: 2019-05-24 17:02
To: [email protected]
CC: user
Subject: Re: How can i just implement a crontab function using flink?
There is concept of periodic watermarker , you can use that
if you are working on eventtime.
On Fri, May 24, 2019 at 1:51 PM [email protected]
<[email protected]> wrote:
I want to do something every one minute.
Using TumblingWindow, the function will not be triigged if there's no message
received during this minute. But i still need to execute the funtion.
How can i implement it ?
[email protected]
--
Cheers
Puneet Kinra
Mobile:+918800167808 | Skype : [email protected]
e-mail :[email protected]
