Я хочу получить количество обработанных и необработанных данных из Apache Spark, используя python.Я ссылался на различные онлайн-материалы, но не смог понять решение.
Ссылки на упомянутое решение: - http://apache -spark-developers-list.1001551.n3.nabble.com /Registration-custom-metrics-td9030.html # a9968
Как получить общее количество записей, обработанных Spark Streaming?
Это то, что у меня естьв качестве выхода.Я хочу получить обработанные и необработанные данные из этого. введите описание изображения здесь