-
Type: Improvement
-
Resolution: Won't Fix
-
Priority: Unknown
-
None
-
Affects Version/s: None
-
Component/s: None
This is an extension to SPARK-324. The following APIs are being requested in MongoSpark:
def save[D](dataset: Dataset[D], writeConfig: WriteConfig, mongoConnector: MongoConnector): Unit
def save[D](javaRDD: JavaRDD[D], writeConfig: WriteConfig, mongoConnector: MongoConnector, clazz: Class[D]): Unit
def save(javaRDD: JavaRDD[Document], writeConfig: WriteConfig, mongoConnector: MongoConnector): Unit
- is related to
-
SPARK-324 MongoSpark SAVE API which accepts MongoConnector instance as argument
- Closed