Funções de Janela no Flink: Redução, Agregação e Processamento Detalhados
1. Utilizando a função ReduceFunction
A função ReduceFunction combina dois elementos para produzir um elemento do mesmo tipo. Ela é executada de forma incremental, após a função KeyBy.
package flink.java.test;
import org.apache.flink.api.common.functions.ReduceFunction;
import org.apache.flink.api.java.tuple.Tuple3;
import org.apache.flink.st ...
Publicado em 7-8 03:42