flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: Trying to detecting changes
Date Wed, 20 Apr 2016 12:02:53 GMT
Hi,
this could be done by implementing a user function that keeps state or by
using windows with a custom Trigger. On only works, however, if you only
have one Kafka partition and if your Flink job is executing with
parallelism=1. Otherwise we don't have any ordering guarantees on streams.

Cheers,
Aljoscha

On Wed, 20 Apr 2016 at 12:50 <toletum@toletum.org> wrote:

> 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?
>

Mime
View raw message