Package com.mongodb.client.model
Class Aggregates
java.lang.Object
com.mongodb.client.model.Aggregates
Builders for aggregation pipeline stages.
- Since:
- 3.1
- MongoDB documentation
- Aggregation pipeline
- Since server release
- 2.2
-
Method Summary
Modifier and TypeMethodDescriptionstatic BsonCreates an $addFields pipeline stagestatic BsonCreates an $addFields pipeline stagestatic <TExpression,Boundary>
BsonCreates a $bucket pipeline stagestatic <TExpression,TBoundary>
Bsonbucket(TExpression groupBy, List<TBoundary> boundaries, BucketOptions options) Creates a $bucket pipeline stagestatic <TExpression>
BsonbucketAuto(TExpression groupBy, int buckets) Creates a $bucketAuto pipeline stagestatic <TExpression>
BsonbucketAuto(TExpression groupBy, int buckets, BucketAutoOptions options) Creates a $bucketAuto pipeline stagestatic Bsoncount()Creates a $count pipeline stage using the field name "count" to store the resultstatic BsonCreates a $count pipeline stage using the named field to store the resultstatic Bsondensify(String field, DensifyRange range) Creates a$densifypipeline stage, which adds documents to a sequence of documents where certain values in thefieldare missing.static Bsondensify(String field, DensifyRange range, DensifyOptions options) Creates a$densifypipeline stage, which adds documents to a sequence of documents where certain values in thefieldare missing.static BsonCreates a facet pipeline stagestatic BsonCreates a facet pipeline stagestatic Bsonfill(FillOptions options, FillOutputField output, FillOutputField... moreOutput) Creates a$fillpipeline stage, which assigns values to fields when they areNullor missing.static Bsonfill(FillOptions options, Iterable<? extends FillOutputField> output) Creates a$fillpipeline stage, which assigns values to fields when they areNullor missing.static <TExpression>
BsongraphLookup(String from, TExpression startWith, String connectFromField, String connectToField, String as) Creates a graphLookup pipeline stage for the specified filterstatic <TExpression>
BsongraphLookup(String from, TExpression startWith, String connectFromField, String connectToField, String as, GraphLookupOptions options) Creates a graphLookup pipeline stage for the specified filterstatic <TExpression>
BsonCreates a $group pipeline stage for the specified filterstatic <TExpression>
BsonCreates a $group pipeline stage for the specified filterstatic Bsonlimit(int limit) Creates a $limit pipeline stage for the specified filterstatic BsonCreates a $lookup pipeline stage, joining the current collection with the one specified in from using equality match between the local field and the foreign fieldstatic BsonCreates a $lookup pipeline stage, joining the current collection with the one specified in from using the given pipelinestatic <TExpression>
BsonCreates a $lookup pipeline stage, joining the current collection with the one specified in from using the given pipelinestatic BsonCreates a $match pipeline stage for the specified filterstatic Bsonmerge(MongoNamespace namespace) Creates a $merge pipeline stage that merges into the specified namespacestatic Bsonmerge(MongoNamespace namespace, MergeOptions options) Creates a $merge pipeline stage that merges into the specified namespace using the specified options.static BsonCreates a $merge pipeline stage that merges into the specified collectionstatic Bsonmerge(String collectionName, MergeOptions options) Creates a $merge pipeline stage that merges into the specified collection using the specified options.static BsonCreates a $out pipeline stage that writes into the specified collectionstatic BsonCreates a $out pipeline stage that supports outputting to a different database.static BsonCreates a $out pipeline stage that writes out to the specified destinationstatic BsonCreates a $project pipeline stage for the specified projectionstatic <TExpression>
BsonreplaceRoot(TExpression value) Creates a $replaceRoot pipeline stagestatic <TExpression>
BsonreplaceWith(TExpression value) Creates a $replaceRoot pipeline stagestatic Bsonsample(int size) Creates a $sample pipeline stage with the specified sample sizestatic Bsonsearch(SearchCollector collector) Creates a$searchpipeline stage supported by MongoDB Atlas.static Bsonsearch(SearchCollector collector, SearchOptions options) Creates a$searchpipeline stage supported by MongoDB Atlas.static Bsonsearch(SearchOperator operator) Creates a$searchpipeline stage supported by MongoDB Atlas.static Bsonsearch(SearchOperator operator, SearchOptions options) Creates a$searchpipeline stage supported by MongoDB Atlas.static BsonsearchMeta(SearchCollector collector) Creates a$searchMetapipeline stage supported by MongoDB Atlas.static BsonsearchMeta(SearchCollector collector, SearchOptions options) Creates a$searchMetapipeline stage supported by MongoDB Atlas.static BsonsearchMeta(SearchOperator operator) Creates a$searchMetapipeline stage supported by MongoDB Atlas.static BsonsearchMeta(SearchOperator operator, SearchOptions options) Creates a$searchMetapipeline stage supported by MongoDB Atlas.static BsonCreates a $set pipeline stage for the specified projectionstatic BsonCreates a $set pipeline stage for the specified projectionstatic <TExpression>
BsonsetWindowFields(TExpression partitionBy, Bson sortBy, WindowOutputField output, WindowOutputField... moreOutput) Creates a$setWindowFieldspipeline stage, which allows using window operators.static <TExpression>
BsonsetWindowFields(TExpression partitionBy, Bson sortBy, Iterable<? extends WindowOutputField> output) Creates a$setWindowFieldspipeline stage, which allows using window operators.static Bsonskip(int skip) Creates a $skip pipeline stagestatic BsonCreates a $sort pipeline stage for the specified sort specificationstatic <TExpression>
BsonsortByCount(TExpression filter) Creates a $sortByCount pipeline stage for the specified filterstatic BsonCreates a $unionWith pipeline stage.static BsonCreates a $unwind pipeline stage for the specified field name, which must be prefixed by a'$'sign.static Bsonunwind(String fieldName, UnwindOptions unwindOptions) Creates a $unwind pipeline stage for the specified field name, which must be prefixed by a'$'sign.
-
Method Details
-
addFields
Creates an $addFields pipeline stage- Parameters:
fields- the fields to add- Returns:
- the $addFields pipeline stage
- Since:
- 3.4
- MongoDB documentation
- $addFields
- Since server release
- 3.4
-
addFields
Creates an $addFields pipeline stage- Parameters:
fields- the fields to add- Returns:
- the $addFields pipeline stage
- Since:
- 3.4
- MongoDB documentation
- $addFields
- Since server release
- 3.4
-
set
Creates a $set pipeline stage for the specified projection- Parameters:
fields- the fields to add- Returns:
- the $set pipeline stage
- Since:
- 4.3
- See Also:
-
set
Creates a $set pipeline stage for the specified projection- Parameters:
fields- the fields to add- Returns:
- the $set pipeline stage
- Since:
- 4.3
- See Also:
-
bucket
Creates a $bucket pipeline stage -
bucket
public static <TExpression,TBoundary> Bson bucket(TExpression groupBy, List<TBoundary> boundaries, BucketOptions options) Creates a $bucket pipeline stage- Type Parameters:
TExpression- the groupBy expression typeTBoundary- the boundary type- Parameters:
groupBy- the criteria to group Byboundaries- the boundaries of the bucketsoptions- the optional values for the $bucket stage- Returns:
- the $bucket pipeline stage
- Since:
- 3.4
-
bucketAuto
Creates a $bucketAuto pipeline stage- Type Parameters:
TExpression- the groupBy expression type- Parameters:
groupBy- the criteria to group Bybuckets- the number of the buckets- Returns:
- the $bucketAuto pipeline stage
- Since:
- 3.4
- MongoDB documentation
- $bucketAuto
- Since server release
- 3.4
-
bucketAuto
public static <TExpression> Bson bucketAuto(TExpression groupBy, int buckets, BucketAutoOptions options) Creates a $bucketAuto pipeline stage- Type Parameters:
TExpression- the groupBy expression type- Parameters:
groupBy- the criteria to group Bybuckets- the number of the bucketsoptions- the optional values for the $bucketAuto stage- Returns:
- the $bucketAuto pipeline stage
- Since:
- 3.4
- MongoDB documentation
- $bucketAuto
- Since server release
- 3.4
-
count
Creates a $count pipeline stage using the field name "count" to store the result -
count
Creates a $count pipeline stage using the named field to store the result -
match
Creates a $match pipeline stage for the specified filter -
project
Creates a $project pipeline stage for the specified projection- Parameters:
projection- the projection- Returns:
- the $project pipeline stage
- See Also:
- MongoDB documentation
- $project
-
sort
Creates a $sort pipeline stage for the specified sort specification -
sortByCount
Creates a $sortByCount pipeline stage for the specified filter- Type Parameters:
TExpression- the expression type- Parameters:
filter- the filter specification- Returns:
- the $sortByCount pipeline stage
- Since:
- 3.4
- MongoDB documentation
- $sortByCount
- Since server release
- 3.4
-
skip
Creates a $skip pipeline stage- Parameters:
skip- the number of documents to skip- Returns:
- the $skip pipeline stage
- MongoDB documentation
- $skip
-
limit
Creates a $limit pipeline stage for the specified filter- Parameters:
limit- the limit- Returns:
- the $limit pipeline stage
- MongoDB documentation
- $limit
-
lookup
Creates a $lookup pipeline stage, joining the current collection with the one specified in from using equality match between the local field and the foreign field- Parameters:
from- the name of the collection in the same database to perform the join with.localField- the field from the local collection to match values against.foreignField- the field in the from collection to match values against.as- the name of the new array field to add to the input documents.- Returns:
- the $lookup pipeline stage
- Since:
- 3.2
-
lookup
Creates a $lookup pipeline stage, joining the current collection with the one specified in from using the given pipeline- Parameters:
from- the name of the collection in the same database to perform the join with.pipeline- the pipeline to run on the joined collection.as- the name of the new array field to add to the input documents.- Returns:
- the $lookup pipeline stage
- Since:
- 3.7
-
lookup
public static <TExpression> Bson lookup(String from, @Nullable List<Variable<TExpression>> let, List<? extends Bson> pipeline, String as) Creates a $lookup pipeline stage, joining the current collection with the one specified in from using the given pipeline- Type Parameters:
TExpression- the Variable value expression type- Parameters:
from- the name of the collection in the same database to perform the join with.let- the variables to use in the pipeline field stages.pipeline- the pipeline to run on the joined collection.as- the name of the new array field to add to the input documents.- Returns:
- the $lookup pipeline stage
- Since:
- 3.7
-
facet
Creates a facet pipeline stage -
facet
Creates a facet pipeline stage -
graphLookup
public static <TExpression> Bson graphLookup(String from, TExpression startWith, String connectFromField, String connectToField, String as) Creates a graphLookup pipeline stage for the specified filter- Type Parameters:
TExpression- the expression type- Parameters:
from- the collection to querystartWith- the expression to start the graph lookup withconnectFromField- the from fieldconnectToField- the to fieldas- name of field in output document- Returns:
- the $graphLookup pipeline stage
- Since:
- 3.4
- MongoDB documentation
- $graphLookup
- Since server release
- 3.4
-
graphLookup
public static <TExpression> Bson graphLookup(String from, TExpression startWith, String connectFromField, String connectToField, String as, GraphLookupOptions options) Creates a graphLookup pipeline stage for the specified filter- Type Parameters:
TExpression- the expression type- Parameters:
from- the collection to querystartWith- the expression to start the graph lookup withconnectFromField- the from fieldconnectToField- the to fieldas- name of field in output documentoptions- optional values for the graphLookup- Returns:
- the $graphLookup pipeline stage
- Since:
- 3.4
- MongoDB documentation
- $graphLookup
- Since server release
- 3.4
-
group
Creates a $group pipeline stage for the specified filter- Type Parameters:
TExpression- the expression type- Parameters:
id- the id expression for the group, which may be nullfieldAccumulators- zero or more field accumulator pairs- Returns:
- the $group pipeline stage
- MongoDB documentation
- $group
- Expressions
-
group
Creates a $group pipeline stage for the specified filter- Type Parameters:
TExpression- the expression type- Parameters:
id- the id expression for the group, which may be nullfieldAccumulators- zero or more field accumulator pairs- Returns:
- the $group pipeline stage
- MongoDB documentation
- $group
- Expressions
-
unionWith
Creates a $unionWith pipeline stage.- Parameters:
collection- the name of the collection in the same database to perform the union with.pipeline- the pipeline to run on the union.- Returns:
- the $unionWith pipeline stage
- Since:
- 4.1
- MongoDB documentation
- $unionWith
- Since server release
- 4.4
-
unwind
Creates a $unwind pipeline stage for the specified field name, which must be prefixed by a'$'sign.- Parameters:
fieldName- the field name, prefixed by a'$' sign- Returns:
- the $unwind pipeline stage
- MongoDB documentation
- $unwind
-
unwind
Creates a $unwind pipeline stage for the specified field name, which must be prefixed by a'$'sign. -
out
Creates a $out pipeline stage that writes into the specified collection- Parameters:
collectionName- the collection name- Returns:
- the $out pipeline stage
- MongoDB documentation
- $out
-
out
Creates a $out pipeline stage that supports outputting to a different database. -
out
Creates a $out pipeline stage that writes out to the specified destination- Parameters:
destination- the destination details- Returns:
- the $out pipeline stage
- Since:
- 4.1
- MongoDB documentation
- $out
-
merge
Creates a $merge pipeline stage that merges into the specified collection -
merge
Creates a $merge pipeline stage that merges into the specified namespace -
merge
Creates a $merge pipeline stage that merges into the specified collection using the specified options. -
merge
Creates a $merge pipeline stage that merges into the specified namespace using the specified options. -
replaceRoot
Creates a $replaceRoot pipeline stage- Type Parameters:
TExpression- the new root type- Parameters:
value- the new root value- Returns:
- the $replaceRoot pipeline stage
- Since:
- 3.4
- MongoDB documentation
- $replaceRoot
- Since server release
- 3.4
-
replaceWith
Creates a $replaceRoot pipeline stageWith $replaceWith, you can promote an embedded document to the top-level. You can also specify a new document as the replacement.
The $replaceWith is an alias for
replaceRoot(Object).- Type Parameters:
TExpression- the new root type- Parameters:
value- the new root value- Returns:
- the $replaceRoot pipeline stage
- Since:
- 3.11
- MongoDB documentation
- $replaceWith
- Since server release
- 4.2
-
sample
Creates a $sample pipeline stage with the specified sample size -
setWindowFields
public static <TExpression> Bson setWindowFields(@Nullable TExpression partitionBy, @Nullable Bson sortBy, WindowOutputField output, WindowOutputField... moreOutput) Creates a$setWindowFieldspipeline stage, which allows using window operators. This stage partitions the input documents similarly to the$grouppipeline stage, optionally sorts them, computes fields in the documents by computing window functions over windows specified per function, and outputs the documents. The important difference from the$grouppipeline stage is that documents belonging to the same partition or window are not folded into a single document.- Type Parameters:
TExpression- ThepartitionByexpression type.- Parameters:
partitionBy- Optional partitioning of data specified likeidingroup(Object, List). Ifnull, then all documents belong to the same partition.sortBy- Fields to sort by. The syntax is identical tosortinsort(Bson)(seeSorts). Sorting is required by certain functions and may be required by some windows (seeWindowsfor more details). Sorting is used only for the purpose of computing window functions and does not guarantee ordering of the output documents.output- A windowed computation.moreOutput- More windowed computations.- Returns:
- The
$setWindowFieldspipeline stage. - Since:
- 4.3
- MongoDB documentation
- $setWindowFields
- Since server release
- 5.0
-
setWindowFields
public static <TExpression> Bson setWindowFields(@Nullable TExpression partitionBy, @Nullable Bson sortBy, Iterable<? extends WindowOutputField> output) Creates a$setWindowFieldspipeline stage, which allows using window operators. This stage partitions the input documents similarly to the$grouppipeline stage, optionally sorts them, computes fields in the documents by computing window functions over windows specified per function, and outputs the documents. The important difference from the$grouppipeline stage is that documents belonging to the same partition or window are not folded into a single document.- Type Parameters:
TExpression- ThepartitionByexpression type.- Parameters:
partitionBy- Optional partitioning of data specified likeidingroup(Object, List). Ifnull, then all documents belong to the same partition.sortBy- Fields to sort by. The syntax is identical tosortinsort(Bson)(seeSorts). Sorting is required by certain functions and may be required by some windows (seeWindowsfor more details). Sorting is used only for the purpose of computing window functions and does not guarantee ordering of the output documents.output- A list of windowed computations. Specifying an empty list is not an error, but the resulting stage does not do anything useful.- Returns:
- The
$setWindowFieldspipeline stage. - Since:
- 4.3
- MongoDB documentation
- $setWindowFields
- Since server release
- 5.0
-
densify
Creates a$densifypipeline stage, which adds documents to a sequence of documents where certain values in thefieldare missing.- Parameters:
field- The field to densify.range- The range.- Returns:
- The requested pipeline stage.
- Since:
- 4.7
- MongoDB documentation
- $densify
- Dot notation
- Since server release
- 5.1
-
densify
Creates a$densifypipeline stage, which adds documents to a sequence of documents where certain values in thefieldare missing.- Parameters:
field- The field to densify.range- The range.options- The densify options. SpecifyingDensifyOptions.densifyOptions()is equivalent to callingdensify(String, DensifyRange).- Returns:
- The requested pipeline stage.
- Since:
- 4.7
- MongoDB documentation
- $densify
- Dot notation
- Since server release
- 5.1
-
fill
Creates a$fillpipeline stage, which assigns values to fields when they areNullor missing.- Parameters:
options- The fill options.output- TheFillOutputField.moreOutput- MoreFillOutputFields.- Returns:
- The requested pipeline stage.
- Since:
- 4.7
-
fill
Creates a$fillpipeline stage, which assigns values to fields when they areNullor missing.- Parameters:
options- The fill options.output- The non-emptyFillOutputFields.- Returns:
- The requested pipeline stage.
- Since:
- 4.7
-
search
Creates a$searchpipeline stage supported by MongoDB Atlas. You may use the$meta: "searchScore"expression, e.g., viaProjections.metaSearchScore(String), to extract the relevance score assigned to each found document.Filters.text(String, TextSearchOptions)is a legacy text search alternative.- Parameters:
operator- A search operator.- Returns:
- The
$searchpipeline stage. - Since:
- 4.7
- MongoDB Atlas documentation
- $search
- Search operators
- Scoring
-
search
Creates a$searchpipeline stage supported by MongoDB Atlas. You may use the$meta: "searchScore"expression, e.g., viaProjections.metaSearchScore(String), to extract the relevance score assigned to each found document.Filters.text(String, TextSearchOptions)is a legacy text search alternative.- Parameters:
operator- A search operator.options- Optional$searchpipeline stage fields. SpecifyingSearchOptions.searchOptions()is equivalent to callingsearch(SearchOperator).- Returns:
- The
$searchpipeline stage. - Since:
- 4.7
- MongoDB Atlas documentation
- $search
- Search operators
- Scoring
-
search
Creates a$searchpipeline stage supported by MongoDB Atlas. You may use$meta: "searchScore", e.g., viaProjections.metaSearchScore(String), to extract the relevance score assigned to each found document.- Parameters:
collector- A search collector.- Returns:
- The
$searchpipeline stage. - Since:
- 4.7
- MongoDB Atlas documentation
- $search
- Search collectors
- Scoring
-
search
Creates a$searchpipeline stage supported by MongoDB Atlas. You may use$meta: "searchScore", e.g., viaProjections.metaSearchScore(String), to extract the relevance score assigned to each found document.- Parameters:
collector- A search collector.options- Optional$searchpipeline stage fields. SpecifyingSearchOptions.searchOptions()is equivalent to callingsearch(SearchCollector).- Returns:
- The
$searchpipeline stage. - Since:
- 4.7
- MongoDB Atlas documentation
- $search
- Search collectors
- Scoring
-
searchMeta
Creates a$searchMetapipeline stage supported by MongoDB Atlas. Unlike$search, it does not return found documents, instead it returns metadata, which in case of using the$searchstage may be extracted by using$$SEARCH_METAvariable, e.g., viaProjections.computedSearchMeta(String).- Parameters:
operator- A search operator.- Returns:
- The
$searchMetapipeline stage. - Since:
- 4.7
- MongoDB Atlas documentation
- $searchMeta
- Search operators
-
searchMeta
Creates a$searchMetapipeline stage supported by MongoDB Atlas. Unlike$search, it does not return found documents, instead it returns metadata, which in case of using the$searchstage may be extracted by using$$SEARCH_METAvariable, e.g., viaProjections.computedSearchMeta(String).- Parameters:
operator- A search operator.options- Optional$searchpipeline stage fields. SpecifyingSearchOptions.searchOptions()is equivalent to callingsearchMeta(SearchOperator).- Returns:
- The
$searchMetapipeline stage. - Since:
- 4.7
- MongoDB Atlas documentation
- $searchMeta
- Search operators
-
searchMeta
Creates a$searchMetapipeline stage supported by MongoDB Atlas. Unlike$search, it does not return found documents, instead it returns metadata, which in case of using the$searchstage may be extracted by using$$SEARCH_METAvariable, e.g., viaProjections.computedSearchMeta(String).- Parameters:
collector- A search collector.- Returns:
- The
$searchMetapipeline stage. - Since:
- 4.7
- MongoDB Atlas documentation
- $searchMeta
- Search collectors
-
searchMeta
Creates a$searchMetapipeline stage supported by MongoDB Atlas. Unlike$search, it does not return found documents, instead it returns metadata, which in case of using the$searchstage may be extracted by using$$SEARCH_METAvariable, e.g., viaProjections.computedSearchMeta(String).- Parameters:
collector- A search collector.options- Optional$searchpipeline stage fields. SpecifyingSearchOptions.searchOptions()is equivalent to callingsearchMeta(SearchCollector).- Returns:
- The
$searchMetapipeline stage. - Since:
- 4.7
- MongoDB Atlas documentation
- $searchMeta
- Search collectors
-