Comment utiliser Flink Java API pour compter distinct dans un DataStream

Question

J'ai rencontré le même problème que How to count unique words in a stream? dans la programmation Flink. Cependant, la réponse a utilisé l'API Scala pour résoudre le problème. Est-ce que Flink Java API prend en charge la transformation filterWithState? L'API Java peut-elle résoudre le problème?

Answer 1

filterWithState et mapWithState sont des morceaux de sucre syntaxique pour l'API Flink Scala qui ne sont pas disponibles dans l'API Java. Mais les mécanismes sous-jacents pour écrire des transformations et des filtres avec état sont en effet là en Java - voir le documentation.