Загрузить коллекцию Mongo на карту, используя MongoSpark - PullRequest
0 голосов
/ 04 сентября 2018

Я пытаюсь загрузить коллекцию искр Монго в карту скалы. Вот что я имею до сих пор:

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()

У меня проблема с отладкой, и я хочу выяснить, правильный ли это путь.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...