Class | Description |
---|---|
IterateExample |
Example illustrating iterations in Flink streaming.
|
IterateExample.InputMap |
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
|
IterateExample.MySelector |
OutputSelector testing which tuple needs to be iterated again.
|
IterateExample.OutputMap |
Giving back the input pair and the counter
|
IterateExample.Step |
Iteration step function that calculates the next Fibonacci number
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.