flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: About delta awareness caches
Date Thu, 01 Dec 2016 11:56:23 GMT
I'm not aware of how windows work in Storm. If you could maybe give some
details on your use case we could figure out together how that would map to
Flink windows.


On Tue, 29 Nov 2016 at 15:47 xingcan <xingcanc@gmail.com> wrote:

> Hi all,
> Recently I tried to transfer some old applications from Storm to Flink.
> In Storm, the window implementation (TupleWindow) gets two methods named
> getNew() and getExpired() which supply the delta information of a window
> and therefore we wrote some stateful caches that are aware of them.
> However, it seems that Flink deals with the window in a different way and
> supplies more "formalized" APIs.
> So, any tips on how to adapt these delta awareness caches in Flink or do
> some refactors to make them suitable?
> Thanks.
> Best,
> Xingcan

View raw message