flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Niklas Semmler <nik...@inet.tu-berlin.de>
Subject Sorting in a WindowedDataStream
Date Tue, 14 Apr 2015 10:12:29 GMT
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

Mime
View raw message