flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stefano Baghino <stefano.bagh...@radicalbit.io>
Subject Re: Trying to detecting changes
Date Wed, 20 Apr 2016 12:43:56 GMT
Can the CEP library be used for this use case?

On Wed, Apr 20, 2016 at 2:02 PM, Aljoscha Krettek <aljoscha@apache.org>
wrote:

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


-- 
BR,
Stefano Baghino

Software Engineer @ Radicalbit

Mime
View raw message