2015-11-20 3 views
4

Я использую разъем Hadoop Монго в Java (искровой приложение) .I've сделано чтение Монго дб, установив эту конфигурациюМонго-Hadoop: как запрашивать данные

Configuration mongodbConfig = new Configuration(); 
mongodbConfig.set("mongo.job.input.format", "com.mongodb.hadoop.MongoInputFormat"); 
mongodbConfig.set("mongo.input.uri", "mongodb://localhost:27017/MyCollectionName.collection"); 

Что я могу добавить для запроса данные (как .limit(100000))

+1

Насколько я знаю, это невозможно. – zero323

ответ

2

Вы можете добавить дополнительные параметры в конфигурации пример:

mongodbConfig.set("mongo.input.query", "{'field':'value'}"); 

см https://github.com/mongodb/mongo-hadoop/wiki/Configuration-Reference для получения более подробной информации

+0

ограничение установлен используя: mongo.input.limit –

Смежные вопросы