Hi Ron,
I think your colleague might be able to do that using a ProcessFunction with
MapState and timers. The MapState is used to determine if a record is new.
Timers would be used to schedule emission and also to schedule cleanup of of
entries from the MapState. For doing cleanup, the entries
Hi,
Assuming FLINK-6465 lands, will something like
SELECT COUNT(*) FROM (SELECT FIRST_VALUE(names) FROM stream) GROUP BY
HOP(proctime, INTERVAL '1' MINUTE, INTERVAL '1' MINUTE)
works?
~Haohui
On Fri, Sep 29, 2017 at 6:52 PM Ron Crocker wrote:
> Hi -
>
> I have a colleague who is trying to wr
Hi -
I have a colleague who is trying to write a flink job that will determine
deltas from period to period. Let’s say the periods are 1 minutes. What he
would like to do is report in minute 2 those things that are new since from
minute 1, then in minute 3 report those things that are new also
