Вопрос по обработке сообщений в Spark - PullRequest
0 голосов
/ 11 декабря 2019

"Предположим, вы внедрили скользящее окно в задание обработки потока с размером окна 300 секунд и шагом перемещения 5 секунд. Сколько раз каждое сообщение обрабатывается вашей работой?"

IЯ должен был ответить на этот вопрос, и я провел некоторое исследование сам, и я все еще не уверен, какой правильный ответ на него. Некоторое объяснение будет с благодарностью. Спасибо!

...