在使用pig和mongodb导入数据时添加mongo查询

8mmmxcuj 于 2021-05-30 发布在 Hadoop

关注(0)|答案(1)|浏览(389)

在ApachePig中使用mongoloader导入数据时如何附加查询。我可以在mongohadoopwiki中看到“mongo.input.query”的引用，但它似乎与标准的map reduce功能有关，而不是apachepig。

raw = LOAD 'mongodb://localhost:27017/demo.yield_historical' USING com.mongodb.hadoop.pig.MongoLoader;

会和这个相似吗？

raw = LOAD 'mongodb://localhost:27017/demo.yield_historical' USING com.mongodb.hadoop.pig.MongoLoader WITH mongo.input.query={"_id":{"$gt":{"$date":1182470400000}}};

hadoop mongodb apache-pig hadoop-plugins mongodb-query

来源：https://stackoverflow.com/questions/28933425/adding-a-mongo-query-when-importing-data-with-pig-and-mongodb

1条答案

按热度按时间

y0u0uwnf1#

你可以这样做：

set mongo.input.query '{"value.task.creation":{ "$gte": { "$date": 1421366400}, "$lt" : { "$date": 1421539200} } }'

data = LOAD 'mongodb://54.93.131.188:27017/foo.units'
          USING com.mongodb.hadoop.pig.MongoLoader(); 
DUMP data;

赞(0）回复(0）举报 2021-05-30

我来回答

在使用pig和mongodb导入数据时添加mongo查询

1条答案

相关问题

热门标签

最新问答