Hello there,
What functions should be used to aggregate (unordered) tuples for every
window in a WindowedDataStream to a (ordered) list?
Neither foldWindow nor reduceWindow seems to be applicable, and
aggregate does not, to my understanding, take user-defined functions.
To get started with flink I am experimenting with the
WindowedDataStream. My goal is to naively compute the top-k from a
stream of key-value tuples.
From: Input over SocketTextStream
previous window, (a, 1), (b, 3), (c, 2), next window
To:
[previous window], [(b, 3), (c, 2), (a, 1)], [next window]
Is this behavior not possible?
Best,
Niklas
--
PhD Student / Research Assistant
INET, TU Berlin
Room 4.029
Marchstr 23
10587 Berlin
Tel: +49 30 314 78752
