Я пытаюсь прочитать json и разобрать два значения valueStr1 и valueStr2 из темы Кафки...

Использование потоковой передачи Spark для чтения данных Json из раздела Kafka. Я использую...

Я использую приемник для сохранения Spark (2.3) Структурированного потокового фрейма данных в...

У меня есть следующий код: - import org.apache.spark.sql.functions.from_json val ds = df

Я создаю пустой фрейм данных и позже пытаюсь добавить к нему другой фрейм данных. На самом деле я...

Я использую Streaming для получения записей о звонках от брокера Kakfa каждые 10 минут. Я хочу...