Структурированная потоковая передача Spark в режиме добавления, выводящая множество строк за одно временное окно
#pyspark #spark-structured-streaming Вопрос: Я пишу непрерывное приложение с помощью Apache Spark. В случае структурированной потоковой передачи я пытаюсь прочитать из дельта-таблицы, выполнить агрегацию потоковой передачи по времени события через временное…