Hi
Because flink use lazy evaluation and because inactivityCEP don't have any
output then you pattern not apply.
/
inactivityCEP.select(new PatternSelectFunction() {
@Override
public Object select(Map pattern) throws
Exception {
System.out.println(pattern);
return null;
}
});
/
>> What am I mis
Hi..Thanks for the reply.
I can see the pattern is not getting data. So what correct I have to do.
I want to apply the pattern only after the window function is executed.
Sorry to say, I could hardly get any info from the documentation.
--
View this message in context:
http://apache-flink-m
Hi
Because flink use lazy evaluation and because inactivityCEP don't have any
output then you pattern not apply.
/
inactivityCEP.select(new PatternSelectFunction() {
@Override
public Object select(Map pattern) throws
Exception {
System.out.println(pattern);
return null;
}
});
/
>> What am I mis
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.c
