在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}}};
1条答案
按热度按时间y0u0uwnf1#
你可以这样做: