assignTimestamp after keyBy

2016-09-07 Thread Dong-iL, Kim
Hi. my stream data is from some files. ( files -> kafka -> flink(source -> keyBy -> windowing) ) data is arranged in a file. I wanna assingTimestamp after keyBy. How can I do that. Regards.

Re: assignTimestamp after keyBy

2016-09-07 Thread pushpendra.jaiswal
ser-mailing-list-archive.2336050.n4.nabble.com/assignTimestamp-after-keyBy-tp8962p8964.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: assignTimestamp after keyBy

2016-09-08 Thread Dong-iL, Kim
> View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/assignTimestamp-after-keyBy-tp8962p8964.html > Sent from the Apache Flink User Mailing List archive. mailing list archive at > Nabble.com.

Re: assignTimestamp after keyBy

2016-09-08 Thread Dong-iL, Kim
k(... >> >> ~Pushpendra >> >> >> >> -- >> View this message in context: >> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/assignTimestamp-after-keyBy-tp8962p8964.html >> Sent from the Apache Flink User Mailing List archive. mailing list archive >> at Nabble.com. >

Re: assignTimestamp after keyBy

2016-09-08 Thread Fabian Hueske
b) => a.add(b) ) > >.addSink(... > > > > ~Pushpendra > > > > > > > > -- > > View this message in context: http://apache-flink-user- > mailing-list-archive.2336050.n4.nabble.com/assignTimestamp- > after-keyBy-tp8962p8964.html > > Sent from the Apache Flink User Mailing List archive. mailing list > archive at Nabble.com. > >