Я пытаюсь выполнить обработку данных с использованием структурированной потоковой передачи.У меня есть необходимость сделать несколько пользовательских агрегации, и я пытаюсь использовать flatMapGroupsWithState.Обработка, которую мне нужно сделать, должна обрабатывать входные данные по порядку.
Мои вопросы: 1. После того, как groupByKey сгруппировал данные, могу ли я как-то отсортировать входные данные, не загружая все их в память в одномвыстрел?2. может ли одно из полей, по которому оно отсортировано, быть отметкой времени структурированного потока?
Пожалуйста, спросите, если что-то не ясно ...
Спасибо