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.
|
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–2018 The Apache Software Foundation. All rights reserved.