flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tole...@toletum.org
Subject Trying to detecting changes
Date Wed, 20 Apr 2016 10:49:55 GMT
Hi! I'm a beginner in Flink.
I'm reading from a Kafka topic. In this topic, I receive a character each event, like that:

Event.: 1 2 3 4 5 6 7 8 9...
Data..: A A A B B B B C C...

I would like to do a "trigger" when the character is different than before. For example:
Event º1 fire because of A is different to "null"
Event º4 fire because of B is different to A
Event º8 fire because of C is different to B

Could it be possible?

View raw message