flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ahmad Hassan <ahmad.has...@gmail.com>
Subject Keyed windows with single sink
Date Thu, 22 Jun 2017 13:15:15 GMT
Hi All,

I am using categoryID as a keyby attribute for creating keyed stream from a
product event stream. Keyed stream then creates time windows for each
category. However, when the window time expires, i want to write the output
data of all the products in all all categories in a single atomic operation
collectively. Is there a way to call a single sink function for all the
windows with same start and end time. Or is there a way in flink to know
that all windows with same end time have finished processing their sink
function?

Currently, each window calls sink function individually.

cheers,

Mime
View raw message