How to save DataFrame into MongoDB using Java API?

[NiranjanMudhiraj]

[lizengfa]

I want to know also:)I use mongo-hadoop-core to save MongoDB now

[darroyocazorla]

Hi @NiranjanMudhiraj @lizengfa

You can create a MongodbDataFrame, and then, save it indicating the config. This is the source code:

class MongodbDataFrame(dataFrame: DataFrame) extends Serializable {

  /**
   * It allows storing data in Mongodb from some existing SchemaRDD
   * @param config MongoDB configuration object
   * @param batch It indicates whether it has to be saved in batch mode or not.
   */
  def saveToMongodb(config: Config, batch: Boolean): Unit = {
}

I hope it helps