Re: Get Window Time

2017-11-02 Thread 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); >

Re: Get Window Time

2017-11-01 Thread 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))) Patte

Re: Get Window Time

2017-11-01 Thread 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] >

Get Window Time

2017-11-01 Thread Erdem erdfem
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]