Я хочу напечатать разделитель для каждого скользящего окна в потоковых данных Flink.Например, это пример подсчета слов из Flink, который печатает подсчитанные слова за последние 10 секунд с шагом 5 секунд.Если он работает правильно, сначала нужно распечатать одно окно через 10 секунд, например,
(love,2)
(test,10)
(hope,5)
(dead,2)
(evil,5)
, и каждые 5 секунд дополнительный вывод (скользящие окна) добавляется к существующему
(love,2)
(test,10)
(hope,5)
(dead,2)
(evil,5)
(love,15)
(test,2)
(hope,4)
(dead,6)
(evil,10)
Но я хочу сделать эти выходные данные различимыми для каждого окна.
-------------------------------------------------
(love,2)
(test,10)
(hope,5)
(dead,2)
(evil,5)
-------------------------------------------------
(love,15)
(test,2)
(hope,4)
(dead,6)
(evil,10)
------------------------------------------------
... And So On
Похоже, что не помогает добавить некоторую функцию преобразования в переменную DataStream для вывода разделителя (то есть apply(), map() и т. Д.).
Простое использование одного System.out.println не решает проблему, поскольку печатает только один раз в начале потока данных DataStream.
Как реализовать эту идею?