下面列出了怎么用com.mongodb.Cursor的API类实例代码及写法,或者点击链接到github查看源代码。
private static Iterator<DBObject> setUpPipelineSample( String query, int numDocsToSample, DBCollection collection )
throws KettleException {
query = query + ", {$limit : " + numDocsToSample + "}"; //$NON-NLS-1$ //$NON-NLS-2$
List<DBObject> samplePipe = jsonPipelineToDBObjectList( query );
Cursor cursor = collection.aggregate( samplePipe, AggregationOptions.builder().build() );
return cursor;
}