#mongodb #apache-spark #pyspark
Вопрос:
Ниже приведен код, который используется
случай 1
df.write.format("com.mongodb.spark.sql.DefaultSource").mode("append").option( "uri", input_uri ).save() случай 2
df.write.format("com.mongodb.spark.sql.DefaultSource").mode("overwrite").option( "uri", input_uri ).save() В обоих сценариях индекс в коллекции mongo удаляется, и это вызывает проблемы с нашей стороны.
Есть ли способ избежать этого в конце искры?
Комментарии:
1. Обновление: Индексы не удаляются, когда мы запускаемся в режиме добавления