MongoDB
 sql >> Database >  >> NoSQL >> MongoDB

Scala:crea un oggetto IndexedDatasetSpark

Rimetterei tutto ciò che hai rimosso, l'errore secondario è autoinflitto.

L'errore originale è dovuto al fatto che non hai creato uno SparkContext, cosa che può essere eseguita:

implicit val mc = mahoutSparkContext()

Successivamente penso che la conversione implicita di mc (a SparkDistributedContext) in sc (a SparkContext) sarà gestita dalle funzioni di supporto del pacchetto. Se manca ancora sc, prova:

implicit val sc = sdc2sc(mc)