I would assign timestamps directly at the source. Timestamps are not striped of by operators.
Reassigning timestamps somewhere in the middle of a job can cause very unexpected results. 2016-09-08 9:32 GMT+02:00 Dong-iL, Kim <kim.s...@gmail.com>: > Thanks for replying. pushpendra. > The assignTimestamp method returns not KeyedStream but DataStream. > so I cannot use windowing. > is it possible casting to KeyedStream? > Regards > > > On Sep 8, 2016, at 3:12 PM, pushpendra.jaiswal < > pushpendra.jaiswa...@gmail.com> wrote: > > > > Please refer > > https://ci.apache.org/projects/flink/flink-docs- > master/dev/event_timestamps_watermarks.html > > for assigning timestamps. > > > > You can do map after keyby to assign timestamps > > > > e.g: > > > > val withTimestampsAndWatermarks: DataStream[MyEvent] = stream > > .filter( _.severity == WARNING ) > > .assignTimestampsAndWatermarks(new MyTimestampsAndWatermarks()) > > > > withTimestampsAndWatermarks > > .keyBy( _.getGroup ) > > .timeWindow(Time.seconds(10)) > > .reduce( (a, 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. > >
