Re: Get Window Time

[Aljoscha Krettek]

@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  wrote:
> 
>  FlinkKafkaConsumer010 myConsumer = new 
> FlinkKafkaConsumer010<>("demo", new JSONDeserializationSchema(),
> properties);
> DataStream dataStream = env.addSource(myConsumer);
>  dataStream.windowAll(SlidingEventTimeWindows.of(Time.hours(1), 
> Time.minutes(1)))
>  
>  
>Pattern warningPattern = 
> Pattern.begin("First Event")
> 
>  .where(new IterativeCondition() {
> @Override
> public boolean filter(ObjectNode jsonNodes, 
> Context context) throws Exception {
>   return 
> jsonNodes.get("property").equals("test")
>   }
>});
> 
>PatternStream patternStream = CEP.pattern(keyedStream, 
> pattern);
>
>  DataStream alarms = patternStream
> .select(new PatternSelectFunction Alert>() {
> private static final long serialVersionUID = 
> 1L;
> 
> public Alert select(Map List> 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  >:
> Can you post the code please
> 
> On 1 Nov 2017 16:58, "Erdem erdfem"  > 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]
> >
> 

Re: Get Window Time

[Erdem erdfem]

 FlinkKafkaConsumer010 myConsumer = new
FlinkKafkaConsumer010<>("demo", new JSONDeserializationSchema(),
properties);
DataStream dataStream =
env.addSource(myConsumer);
  dataStream.windowAll(SlidingEventTimeWindows.of(Time.hours(1),
Time.minutes(1)))


Pattern warningPattern =
Pattern.begin("First Event")

 .where(new IterativeCondition() {
@Override
public boolean filter(ObjectNode jsonNodes,
Context context) throws Exception {
return jsonNodes.get("property").equals("test")
}
});

PatternStream patternStream = CEP.pattern(keyedStream, pattern);

 DataStream alarms = patternStream
.select(new PatternSelectFunction() {
private static final long serialVersionUID
= 1L;

public Alert select(Map 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());

[image: Satır içi resim 1]
If pattern matched on windows2, how can i get window2(time or another
property) ?


2017-11-01 17:59 GMT+03:00 miki haiat :

> Can you post the code please
>
> On 1 Nov 2017 16:58, "Erdem erdfem"  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]
> >
>

Re: Get Window Time

[miki haiat]

Can you post the code please

On 1 Nov 2017 16:58, "Erdem erdfem"  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]
>