Любой пример / реализация приемника foreach в pyspark для выгрузки данных в какую-то другую базу данных, скажем, MongoDB? Я посмотрел в документации, она не дает большого понимания реализации произвольного приемника с использованием foreach в pyspark. Также посмотрел в github, пока не повезло. Все примеры доступны в java или scala. Большое спасибо!