Я пытаюсь загрузить коллекцию искр Монго в карту скалы. Вот что я имею до сих пор:
val mongoUri = "mongodb://<username>:<password>@<mongoHost>:<mongoPort>/<dbName>.<collectionName>"
val readConfig = ReadConfig(Map("spark.mongodb.input.uri" -> <mongo-uri>))
val mapFromMongo = MongoSpark.load(sc, readConfig)
.withPipeline(Seq(Document.parse("{ $match: {\"satisfyingCondition\" :{$eq: true} } }")))
.map(row => (row.getString(1), row.getString(0)))
.collectAsMap()
У меня проблема с отладкой, и я хочу выяснить, правильный ли это путь.