AggregationPipeline |
AggregationPipeline.bucket(java.lang.String field,
java.util.List<?> boundaries) |
Categorizes incoming documents into groups, called buckets, based on a specified expression and
bucket boundaries.
|
AggregationPipeline |
AggregationPipeline.bucket(java.lang.String field,
java.util.List<?> boundaries,
BucketOptions options) |
Categorizes incoming documents into groups, called buckets, based on a specified expression and
bucket boundaries.
|
AggregationPipeline |
AggregationPipelineImpl.bucket(java.lang.String field,
java.util.List<?> boundaries) |
|
AggregationPipeline |
AggregationPipelineImpl.bucket(java.lang.String field,
java.util.List<?> boundaries,
BucketOptions options) |
|
AggregationPipeline |
AggregationPipeline.bucketAuto(java.lang.String field,
int bucketCount) |
Categorizes incoming documents into a specific number of groups, called buckets, based on a
specified expression.
|
AggregationPipeline |
AggregationPipeline.bucketAuto(java.lang.String field,
int bucketCount,
BucketAutoOptions options) |
Categorizes incoming documents into a specific number of groups, called buckets, based on a
specified expression.
|
AggregationPipeline |
AggregationPipelineImpl.bucketAuto(java.lang.String field,
int bucketCount) |
|
AggregationPipeline |
AggregationPipelineImpl.bucketAuto(java.lang.String field,
int bucketCount,
BucketAutoOptions options) |
|
AggregationPipeline |
AggregationPipeline.geoNear(GeoNear geoNear) |
Returns an ordered stream of documents based on the proximity to a geospatial point.
|
AggregationPipeline |
AggregationPipelineImpl.geoNear(GeoNear geoNear) |
|
AggregationPipeline |
AggregationPipeline.group(Group... groupings) |
Groups input documents by a specified identifier expression and applies the accumulator expression(s), if specified, to each group
.
|
AggregationPipeline |
AggregationPipeline.group(java.lang.String id,
Group... groupings) |
Groups input documents by a specified identifier expression and applies the accumulator expression(s), if specified, to each group.
|
AggregationPipeline |
AggregationPipeline.group(java.util.List<Group> id,
Group... groupings) |
|
AggregationPipeline |
AggregationPipelineImpl.group(Group... groupings) |
|
AggregationPipeline |
AggregationPipelineImpl.group(java.lang.String id,
Group... groupings) |
|
AggregationPipeline |
AggregationPipelineImpl.group(java.util.List<Group> id,
Group... groupings) |
|
AggregationPipeline |
AggregationPipeline.limit(int count) |
Passes the first n documents unmodified to the pipeline where n is the specified limit.
|
AggregationPipeline |
AggregationPipelineImpl.limit(int count) |
|
AggregationPipeline |
AggregationPipeline.lookup(java.lang.String from,
java.lang.String localField,
java.lang.String foreignField,
java.lang.String as) |
Performs a left outer join to an unsharded collection in the same database to filter in documents from the "joined" collection for
processing.
|
AggregationPipeline |
AggregationPipelineImpl.lookup(java.lang.String from,
java.lang.String localField,
java.lang.String foreignField,
java.lang.String as) |
|
AggregationPipeline |
AggregationPipeline.match(Query query) |
Filters the document stream to allow only matching documents to pass unmodified into the next pipeline stage.
|
AggregationPipeline |
AggregationPipelineImpl.match(Query query) |
|
AggregationPipeline |
AggregationPipeline.project(Projection... projections) |
Reshapes each document in the stream, such as by adding new fields or removing existing fields.
|
AggregationPipeline |
AggregationPipelineImpl.project(Projection... projections) |
|
AggregationPipeline |
AggregationPipeline.sample(int sampleSize) |
Randomly selects the specified number of documents from the previous pipeline stage.
|
AggregationPipeline |
AggregationPipelineImpl.sample(int sampleSize) |
|
AggregationPipeline |
AggregationPipeline.skip(int count) |
Skips the first n documents where n is the specified skip number and passes the remaining documents unmodified to the pipeline.
|
AggregationPipeline |
AggregationPipelineImpl.skip(int count) |
|
AggregationPipeline |
AggregationPipeline.sort(Sort... sorts) |
Reorders the document stream by a specified sort key.
|
AggregationPipeline |
AggregationPipelineImpl.sort(Sort... sorts) |
|
AggregationPipeline |
AggregationPipeline.sortByCount(java.lang.String field) |
Groups incoming documents based on the value of a specified expression, then computes the count
of documents in each distinct group.
|
AggregationPipeline |
AggregationPipelineImpl.sortByCount(java.lang.String field) |
|
AggregationPipeline |
AggregationPipeline.unwind(java.lang.String field) |
Deconstructs an array field from the input documents to output a document for each element.
|
AggregationPipeline |
AggregationPipeline.unwind(java.lang.String field,
com.mongodb.client.model.UnwindOptions options) |
Deconstructs an array field from the input documents to output a document for each element.
|
AggregationPipeline |
AggregationPipelineImpl.unwind(java.lang.String field) |
|
AggregationPipeline |
AggregationPipelineImpl.unwind(java.lang.String field,
com.mongodb.client.model.UnwindOptions options) |
|