Wie flink Fenster API verwenden, um eine Aggregatfunktion in einem Stream-Fenster pro Sekunde anzuwenden

Question

Ich möchte die Funktion sum auf ein Stream-Fenster anwenden, die Periode ist eine Stunde und die Funktion pro Sekunde ausführen.
Zum Beispiel:
Das aktuelle Fenster ist 13: 00: 00-14: 59: 59 und die aktuelle Uhrzeit ist 13:00:03.
13.00.04: sum auf 13: 00: 00- 13.00.04
13.00.05: sum auf 13: 00: 00- 13.00.05
.
.
.
13.59.59: sum auf 13: 00: 00- 13:59:59

Answer 1

Eine Möglichkeit dies ein ProcessFunction unter Verwendung zu implementieren ist. Mit dieser Funktion können Sie Timer einstellen, die z. feuern jede Sekunde. Die Zwischenergebnisse Ihrer Berechnung können in einem state (z. B. ListState oder ValueState) gespeichert werden.

Eine andere Möglichkeit könnte die Implementierung einer benutzerdefinierten Trigger sein. Trigger definieren, wann ein Fensterausschnitt ausgewertet werden soll. Der Inhalt selbst ist davon nicht betroffen, es sei denn, Sie definieren auch einen benutzerdefinierten Evictor. Here ist ein Beispiel für einen Trigger.