PySpark — Структурированная потоковая передача. Как избежать ожидания данных следующего окна для обработки текущего окна?
#pyspark #apache-kafka #spark-structured-streaming #пыспарк #апач-кафка #спарк-структурированный-потоковый Вопрос: Мое приложение объединяет данные, поступающие от нескольких датчиков, в 5-минутные окна. Данные записываются в Кафку, и приложение pyspark считывает их из Кафки. Приложение…