Как использовать итерации, предусмотренные в Flink ML? ⇐ JAVA

[Гость]

Поскольку метод iterativeStream API DataStream устарел, в качестве альтернативы рекомендуется использовать итерацию Flink ML.
Во-первых, есть ли какой-нибудь простой игрушечный пример, не связанный с машинным обучением, который мы можем работать, используя новую поддержку итераций? Я проверил документацию, но не смог найти конкретного примера.
Во-вторых, я пытаюсь реализовать следующий пример из документации iterativeStream, используя итерацию Flink ML (

Код: Выделить всё

Iterations.iterateUnboundedStreams

), но мне трудно в этом разобраться:

Код: Выделить всё

DataStream someIntegers = env.generateSequence(0, 1000);

IterativeStream iteration = someIntegers.iterate();

DataStream minusOne = iteration.map(new MapFunction() {   @Override   public Long map(Long value) throws Exception {
return value - 1 ;   } });

DataStream stillGreaterThanZero = minusOne.filter(new FilterFunction() {   @Override   public boolean filter(Long value) throws Exception {
return (value > 0);   } });

iteration.closeWith(stillGreaterThanZero);

DataStream lessThanZero = minusOne.filter(new FilterFunction() {   @Override   public boolean filter(Long value) throws Exception {
return (value 

Подробнее здесь: [url]https://stackoverflow.com/questions/78165183/how-to-use-iterations-provided-in-flink-ml[/url]