Apache Storm TICK équivalent tuple en apache flink?

Question

Je suis nouveau à Apache Flink. Je veux enregistrer le nombre d'entrées dans mon cache toutes les heures dans un fichier. Je l'ai fait dans la tempête en utilisant tick tuple. Est-ce que Flink a quelque chose de similaire que je peux utiliser dans un opérateur de flink?

Answer 1

Vous pouvez utiliser un ProcessFunction, qui peut être utilisé avec les minuteurs de temps de traitement et d'événement. Mais je dirais que window operator de Flink est la façon la plus naturelle de compter les choses dans des fenêtres limitées dans le temps.