flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Björn Hedström <bjorn.e.hedst...@gmail.com>
Subject Different watermarks on keyed stream
Date Wed, 09 Aug 2017 07:57:28 GMT

I'm building a small application which reads CSV-files from Kafka and
passes them to Flink. In Flink i parse these values which contains an
embedded timestamp and assign watermarks with a
BoundedOutOfOrdernessTimestampExtractor. Then i "transform" the stream into
a KeyedStream by an ID embedded in the datavalue. These are later processed
by CEP. However since the timestamps may differ depending on extracted ID I
would like to have a seperate watermark for each ID in the keyed stream
before they are processed in CEP. Is this possible and in that case how do
i procceed? Any help would be appreciated.


View raw message