@Kostas, could you maybe have a look? The title says "window" but it's actually
about CEP.
> On 2. Nov 2017, at 07:33, Erdem erdfem <erdemyayla...@gmail.com> wrote:
>
> FlinkKafkaConsumer010<ObjectNode> myConsumer = new
> FlinkKafkaConsumer010<>("demo", new JSONDeserializationSchema(),
> properties);
> DataStream<ObjectNode> dataStream = env.addSource(myConsumer);
> dataStream.windowAll(SlidingEventTimeWindows.of(Time.hours(1),
> Time.minutes(1)))
>
>
> Pattern<MonitoringEvent, ?> warningPattern =
> Pattern.<ObjectNode>begin("First Event")
>
> .where(new IterativeCondition<ObjectNode>() {
> @Override
> public boolean filter(ObjectNode jsonNodes,
> Context<ObjectNode> context) throws Exception {
> return
> jsonNodes.get("property").equals("test")
> }
> });
>
> PatternStream<ObjectNode> patternStream = CEP.pattern(keyedStream,
> pattern);
>
> DataStream<Alert> alarms = patternStream
> .select(new PatternSelectFunction<ObjectNode,
> Alert>() {
> private static final long serialVersionUID =
> 1L;
>
> public Alert select(Map<String,
> List<ObjectNode>> map) throws Exception {
> System.out.println(timeW);
> return new Alert("UniverseId:" +universe
> + "RuleLabel:" +rule.getRuleLabel() +"Value:"+
> map.get("beforeCriteriaFilter").get(0));
> }
> }).keyBy(alert -> alert.getMessage());
>
>
> If pattern matched on windows2, how can i get window2(time or another
> property) ?
>
>
> 2017-11-01 17:59 GMT+03:00 miki haiat <miko5...@gmail.com
> <mailto:miko5...@gmail.com>>:
> Can you post the code please
>
> On 1 Nov 2017 16:58, "Erdem erdfem" <erdemyayla...@gmail.com
> <mailto:erdemyayla...@gmail.com>> wrote:
>
> > Hello,
> >
> > I have a datastream with sliding windows. I want to ask how can i get
> > which window pattern matches?
> > ex window 3 : 11m-21m
> >
> > [image: Satır içi resim 1]
> >
>
