У меня задание со структурированной потоковой передачей, для которого нужно прочитать данные из...

Я получаю непрерывный поток данных о температуре от Кафки.Я классифицирую данные на основе...

Как правильно использовать кэш LRU в памяти в приложении scala, которое работает по искровому...

Я читаю данные из Kafka с использованием Spark Structured Streaming и пытаюсь создать новый столбец...

У меня есть потоковые данные, поступающие из кафки в dataFrame.Я хочу удалить дубликаты на основе...