I wanna assign timestamp after keyBy. because the stream does not aligned before keyBy. I’ve already tested as like your code. It occured many warnings that timestamp monotony violated.
> On Sep 8, 2016, at 4:32 PM, Dong-iL, Kim <kim.s...@gmail.com> wrote: > > 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. >
