Cómo probar la ventana global de Flink con desencadenador y evictor
Tengo un pipeline que utiliza la ventana global de Flink con un disparador personalizado basado en el tiempo de evento (a partir de la marca de tiempo en el elemento que llega) y un eliminador que corta elementos innecesarios de la ventana y los pasa a ProcessFunction, algo así: public . . . Read more