THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||||
---|---|---|---|---|---|---|
| ||||||
val stream: DataStream[(Int, Int, Int)] = env.createStream(new KafkaSource(...))
val windowed: DataStream[(Int, Int, Int)] = stream
.keyBy(0)
.window(TimestampTime.of(5, SECONDS)
.sumByKey(2)
.keyBy(1)
.window(TimestampTime.of(5, SECONDS))
.minByKey(2) |
...