THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
The bounded stream iteration API is
Code Block | ||||||
---|---|---|---|---|---|---|
| ||||||
public class BoundedIteration {
BoundedIteration withBody(BoundedIterationBody body) {
...
}
BoundedIteration bindInput(String name, DataStream<?> input) {
...
}
ResultStreams apply() {
...
}
}
|
Key Implementation
Compatibility, Deprecation, and Migration Plan
...