Создайте состояние для функции RichCoGroup с помощью api процессора состояний
#apache-flink #flink-streaming Вопрос: Я пытаюсь создать точку сохранения (используя API процессора состояний) для функции richcogroup. Поскольку функция CoGroup использует окно, я подумал, что мне нужно написать состояние окна. Из документации…