THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block | ||||||
|---|---|---|---|---|---|---|
| ||||||
val stream: DataStream[MyType] = env.createStream(new KafkaSource(...))
val windowed: DataStream[MyType] = stream
.keyBy(...)
.window(...)
.reduceGroup { ... }
|
...
Semantics of Sequences of Windows
Aligned Time Windows
General Windows
Accessing the Timestamp of
...
an Element
Implementing Windows on Ingress- and Event Time
...