...

The concept of watermarks as used in Flink is inspired by Google's MillWheel: http://research.google.com/pubs/pub41378.html and by work building on top of it for Google Cloud Dataflow API: http://strataconf.com/big-data-conference-uk-2015/public/schedule/speaker/193653

Ordering Records

• Ordering for OrderedKeyDataStream
• Ordering for windows

Image Added	Code Block language scala title DataStream Example linenumbers true val stream: DataStream[MyType] = env.createStream(new KafkaSource(...)) val str1: DataStream[(String, MyType)] = stream.flatMap { ... } val str2: DataStream[(String, MyType)] = stream.rebalance() val str3: DataStream[AnotherType] = stream.map { ... }

Timestamps on Results of Window Operations

...