diff options
author | Eliot Horowitz <eliot@10gen.com> | 2009-11-03 11:40:00 -0500 |
---|---|---|
committer | Eliot Horowitz <eliot@10gen.com> | 2009-11-03 11:40:00 -0500 |
commit | 6d5e43755d739b526d5b56c7a6c457e8f019a74b (patch) | |
tree | cd929539e73fb9f46129ad9bd1c4a9fa016a41cd /client/parallel.h | |
parent | 3a1c9831c135fbef4bf02ac3458772196bd88038 (diff) | |
download | mongo-6d5e43755d739b526d5b56c7a6c457e8f019a74b.tar.gz |
sharded map-reduce basic test works SHARDING-37
Diffstat (limited to 'client/parallel.h')
-rw-r--r-- | client/parallel.h | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/client/parallel.h b/client/parallel.h index e7d39a89ba9..a2189c6c745 100644 --- a/client/parallel.h +++ b/client/parallel.h @@ -87,10 +87,14 @@ namespace mongo { class ParallelSortClusteredCursor : public ClusteredCursor { public: ParallelSortClusteredCursor( set<ServerAndQuery> servers , QueryMessage& q , const BSONObj& sortKey ); + ParallelSortClusteredCursor( set<ServerAndQuery> servers , const string& ns , + const Query& q , int options=0, const BSONObj& fields=BSONObj() ); virtual ~ParallelSortClusteredCursor(); virtual bool more(); virtual BSONObj next(); private: + void _init(); + void advance(); int _numServers; |