my_spark = SparkSession \ .builder \ .appName("DGLE") \
config("spark.mongodb.input.uri", "mongodb://127.0.0.1/local.DGLE") \ getOrCreate()
JDBC.write.format("com.mongodb.spark.sql.DefaultSource").option("spark.mongodb.output.uri", "mongodb://127.0.0.1:27017/local.DGLE").save()
Это мой код, не знаю, где и в чем ошибка, помогите пожалуйста
my_spark = SparkSession \ builder \ .appName("DGLE") \ .config("spark.mongodb.input.uri", "mongodb://127.0.0.1/local.DGLE") \ .getOrCreate()
JDBC.write.format("com.mongodb.spark.sql.DefaultSource").option("spark.mongodb.output.uri", "mongodb://127.0.0.1:27017/local.DGLE").save()