Tôi đã thử giải pháp mà tôi tìm thấy tại đây và nó hoạt động tốt :) .. Tôi sẽ giữ chuỗi và thêm mã của tôi trong trường hợp ai đó cần nó.
var SOURCE = db.sample;
var DEST = db.distinct;
DEST.drop();
map = function() {
emit( this.user.screen_name , {count: 1});
}
reduce = function(key, values) {
var count = 0;
values.forEach(function(v) {
count += v['count'];
});
return {count: count};
};
res = SOURCE.mapReduce( map, reduce,
{ out: 'distinct',
verbose: true
}
);
print( "distinct count= " + res.counts.output );
print( "distinct count=", DEST.count() );
Trân trọng