Aggregation<T> |
Aggregation.addFields(AddFields fields) |
Adds new fields to documents.
|
Aggregation<T> |
AggregationImpl.addFields(AddFields fields) |
|
Aggregation<T> |
Aggregation.autoBucket(AutoBucket bucket) |
Categorizes incoming documents into a specific number of groups, called buckets, based on a specified expression.
|
Aggregation<T> |
AggregationImpl.autoBucket(AutoBucket bucket) |
|
Aggregation<T> |
Aggregation.bucket(Bucket bucket) |
Categorizes incoming documents into groups, called buckets, based on a specified expression and bucket boundaries.
|
Aggregation<T> |
AggregationImpl.bucket(Bucket bucket) |
|
Aggregation<T> |
Aggregation.collStats(CollectionStats stats) |
Returns statistics regarding a collection or view.
|
Aggregation<T> |
AggregationImpl.collStats(CollectionStats stats) |
|
Aggregation<T> |
Aggregation.count(String name) |
Passes a document to the next stage that contains a count of the number of documents input to the stage.
|
Aggregation<T> |
AggregationImpl.count(String name) |
|
Aggregation<T> |
Aggregation.currentOp(CurrentOp currentOp) |
Returns a stream of documents containing information on active and/or dormant operations as well as inactive sessions that are
holding locks as part of a transaction.
|
Aggregation<T> |
AggregationImpl.currentOp(CurrentOp currentOp) |
|
Aggregation<T> |
Aggregation.facet(Facet facet) |
Processes multiple aggregation pipelines within a single stage on the same set of input documents.
|
Aggregation<T> |
AggregationImpl.facet(Facet facet) |
|
Aggregation<T> |
Aggregation.geoNear(GeoNear near) |
Outputs documents in order of nearest to farthest from a specified point.
|
Aggregation<T> |
AggregationImpl.geoNear(GeoNear near) |
|
Aggregation<T> |
Aggregation.graphLookup(GraphLookup lookup) |
Performs a recursive search on a collection, with options for restricting the search by recursion depth and query filter.
|
Aggregation<T> |
AggregationImpl.graphLookup(GraphLookup lookup) |
|
Aggregation<T> |
Aggregation.group(Group group) |
Groups input documents by the specified _id expression and for each distinct grouping, outputs a document.
|
Aggregation<T> |
AggregationImpl.group(Group group) |
|
Aggregation<T> |
Aggregation.indexStats() |
Returns statistics regarding the use of each index for the collection.
|
Aggregation<T> |
AggregationImpl.indexStats() |
|
Aggregation<T> |
Aggregation.limit(long limit) |
Limits the number of documents passed to the next stage in the pipeline.
|
Aggregation<T> |
AggregationImpl.limit(long limit) |
|
Aggregation<T> |
Aggregation.lookup(Lookup lookup) |
Performs a left outer join to an unsharded collection in the same database to filter in documents from the “joined” collection for
processing.
|
Aggregation<T> |
AggregationImpl.lookup(Lookup lookup) |
|
Aggregation<T> |
Aggregation.match(Filter... filters) |
Filters the document stream to allow only matching documents to pass unmodified into the next pipeline stage.
|
Aggregation<T> |
AggregationImpl.match(Filter... filters) |
|
Aggregation<T> |
Aggregation.planCacheStats() |
Returns plan cache information for a collection.
|
Aggregation<T> |
AggregationImpl.planCacheStats() |
|
Aggregation<T> |
Aggregation.project(Projection projection) |
Passes along the documents with the requested fields to the next stage in the pipeline.
|
Aggregation<T> |
AggregationImpl.project(Projection projection) |
|
Aggregation<T> |
Aggregation.redact(Redact redact) |
Restricts the contents of the documents based on information stored in the documents themselves.
|
Aggregation<T> |
AggregationImpl.redact(Redact redact) |
|
Aggregation<T> |
Aggregation.replaceRoot(ReplaceRoot root) |
Replaces the input document with the specified document.
|
Aggregation<T> |
AggregationImpl.replaceRoot(ReplaceRoot root) |
|
Aggregation<T> |
Aggregation.replaceWith(ReplaceWith with) |
Replaces the input document with the specified document.
|
Aggregation<T> |
AggregationImpl.replaceWith(ReplaceWith with) |
|
Aggregation<T> |
Aggregation.sample(long sample) |
Randomly selects the specified number of documents from the previous pipeline stage.
|
Aggregation<T> |
AggregationImpl.sample(long sample) |
|
default Aggregation<T> |
Aggregation.set(AddFields fields) |
Adds new fields to documents.
|
Aggregation<T> |
Aggregation.skip(long skip) |
Skips over the specified number of documents that pass into the stage and passes the remaining documents to the next stage in the
pipeline.
|
Aggregation<T> |
AggregationImpl.skip(long skip) |
|
Aggregation<T> |
Aggregation.sort(Sort sort) |
Sorts all input documents and returns them to the pipeline in sorted order.
|
Aggregation<T> |
AggregationImpl.sort(Sort sort) |
|
Aggregation<T> |
Aggregation.sortByCount(Expression sort) |
Groups incoming documents based on the value of a specified expression, then computes the count of documents in each distinct group.
|
Aggregation<T> |
AggregationImpl.sortByCount(Expression sort) |
|
Aggregation<T> |
Aggregation.unionWith(Class<?> type,
Stage first,
Stage... others) |
Performs a union of two collections; i.e.
|
Aggregation<T> |
Aggregation.unionWith(String collection,
Stage first,
Stage... others) |
Performs a union of two collections; i.e.
|
Aggregation<T> |
AggregationImpl.unionWith(Class<?> type,
Stage first,
Stage... others) |
|
Aggregation<T> |
AggregationImpl.unionWith(String collection,
Stage first,
Stage... others) |
|
Aggregation<T> |
Aggregation.unset(Unset unset) |
Removes/excludes fields from documents.
|
Aggregation<T> |
AggregationImpl.unset(Unset unset) |
|
Aggregation<T> |
Aggregation.unwind(Unwind unwind) |
Deconstructs an array field from the input documents to output a document for each element.
|
Aggregation<T> |
AggregationImpl.unwind(Unwind unwind) |
|