У меня задание со структурированной потоковой передачей, для которого нужно прочитать данные из...
Я получаю непрерывный поток данных о температуре от Кафки.Я классифицирую данные на основе...
Как правильно использовать кэш LRU в памяти в приложении scala, которое работает по искровому...
Я читаю данные из Kafka с использованием Spark Structured Streaming и пытаюсь создать новый столбец...
У меня есть потоковые данные, поступающие из кафки в dataFrame.Я хочу удалить дубликаты на основе...