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.


Reply via email to