#apache-spark #apache-kafka #spark-streaming #rdd #phoenix
Вопрос:
Я работаю с потоковой передачей spark. Приемник(феникс) работает медленнее, чем источник(кафка). Я использую foreachRDD для обработки данных внутри каждого rdd. Как я могу проверить, какие данные rdd в настоящее время обрабатывает. Как получить фактические данные обработки из каждого rdd за определенный промежуток времени.