Example illustrating iterations in Flink streaming.
Map the inputs so that the next Fibonacci numbers can be calculated while preserving the original input tuple A counter is attached to the tuple and incremented in every iteration step
OutputSelector testing which tuple needs to be iterated again.
Giving back the input pair and the counter
Iteration step function that calculates the next Fibonacci number
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.