flink-streaming

Ich stoße auf einige Probleme, die die Semantik rund um das Fenster der Ereigniszeit verstehen. Das folgende Programm generiert einige Tupel mit Zeitstempeln, die als Ereigniszeit verwendet werden und eine einfache Fensteraggregation durchführen...

Gibt es eine Möglichkeit, die Anzahl eindeutiger Wörter in einem Stream mit Flink Streaming zu zählen? Die Ergebnisse wären ein Zahlenstrom, der ständig zunimmt.