flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Alexey Demin <diomi...@gmail.com>
Subject Re: DataStream and CEP - Pattern not matching after applying a window
Date Mon, 09 Jan 2017 05:12:43 GMT
Hi

Because flink use lazy evaluation and because inactivityCEP don't have any
output then you pattern not apply.

/
inactivityCEP.select(new PatternSelectFunction<ObservationEvent, Object>() {
@Override
public Object select(Map<String, ObservationEvent> pattern) throws
Exception {
System.out.println(pattern);

return null;
}
});
/

>> What am I missing
you missing output ;)

2017-01-07 22:47 GMT+04:00 madhairsilence <harish.kumard@tcs.com>:

> Anybody?. Got kinda stuck here :(
>
>
>
> --
> View this message in context: http://apache-flink-mailing-
> list-archive.1008284.n3.nabble.com/DataStream-and-CEP-
> Pattern-not-matching-after-applying-a-window-tp15164p15173.html
> Sent from the Apache Flink Mailing List archive. mailing list archive at
> Nabble.com.
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message