osdir.com


[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Exit pattern matching


Hi Moiz,

What do you mean by exit pattern? Do you mean that you want an event to
belong to a single match? If so I think you can achieve that with
AfterMatchSkip.SKIP_PAST_LAST strategy[1].

[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/libs/cep.html#after-match-skip-strategy

On 22/11/2018 07:26, Moiz Motorwala wrote:
> Hi Flink Team,
>
> First, I would like to thank for such a wonderful tool and appreciate your
> efforts.
> I am developing an application where I am processing stream of geolocations
> and detecting geofence if exactly 3 events are inside geofence. The code is
> something like this:-
>
> Pattern<KafkaLocationEvent, ?> geofencePattern =
> Pattern.<KafkaLocationEvent>begin("matched-events")
>                 .where(new IterativeCondition<KafkaLocationEvent>() {
>
>                     private static final long serialVersionUID = 1L;
>
>                     @Override
>                     public boolean filter(KafkaLocationEvent value,
> Context<KafkaLocationEvent> ctx) throws Exception {
>                         return distanceInMts < geofenceRadiusInMts;
>                     }
>                 }).times(3).consecutive();
>
>                  PatternStream<KafkaTaskEvent> tempPatternStream =
> CEP.pattern(messageStream, geofencePattern);
>
>                  // select matching patterns and generate alerts
>                     DataStream<String> alerts =
> tempPatternStream.select(new GeofenceAlertPatternSelectFunction());
>
> The issue is that alerts are generated even if I get 4th event inside
> geofence and so on. I just want to generate alert once at the first pattern
> match and exit the pattern after that.
>
> As per docs, I am not able to find a relevant function I can use to do
> this. Please help.
> Thanks in Advance.
>

Attachment: signature.asc
Description: OpenPGP digital signature