Я использую автономный кластер Spark 2.3.1. Моя работа сводится к потреблению мини-пакетов Kafka...

В этой статье (https://dzone.com/articles/what-are-spark-checkpoints-on-dataframes)) говорится, что...

У меня есть сценарий, в котором я хочу повторно обработать определенный пакет данных, поступающих...