MongoDB
 sql >> Datenbank >  >> NoSQL >> MongoDB

Scala – IndexedDatasetSpark-Objekt erstellen

Ich würde alles, was Sie entfernt haben, zurücksetzen, der sekundäre Fehler ist selbstverschuldet.

Der ursprüngliche Fehler liegt daran, dass Sie keinen SparkContext erstellt haben, was möglich ist:

implicit val mc = mahoutSparkContext()

Danach denke ich, dass die implizite Konvertierung des mc (ein SparkDistributedContext) in sc (ein SparkContext) von den Pakethilfsfunktionen behandelt wird. Wenn das sc immer noch fehlt, versuchen Sie:

implicit val sc = sdc2sc(mc)