sql >> Database >  >> NoSQL >> MongoDB

Scala - Maak IndexedDatasetSpark-object

Ik zou terugzetten wat je hebt verwijderd, de secundaire fout is door jezelf veroorzaakt.

De oorspronkelijke fout is omdat je geen SparkContext hebt gemaakt, wat kan worden gedaan:

implicit val mc = mahoutSparkContext()

Daarna denk ik dat de impliciete conversie van de mc (een SparkDistributedContext) naar sc (een SparkContext) zal worden afgehandeld door de pakkethelperfuncties. Als de sc nog steeds ontbreekt, probeer dan:

implicit val sc = sdc2sc(mc)



  1. Hoe werk je objecten in de array van een document bij (geneste updates)

  2. MongoDb:aggregatie $lookup met filtering over de buitenlandse documenten

  3. Beannamen van Spring Data-repository's aanpassen voor gebruik met meerdere gegevensbronnen

  4. MongoDB DBref OP VERWIJDEREN CASCADE