public final class Aggregates extends Object
Modifier and Type | Method | Description |
---|---|---|
static Bson |
addFields(Field<?>... fields) |
Creates an $addFields pipeline stage
|
static Bson |
addFields(List<Field<?>> fields) |
Creates an $addFields pipeline stage
|
static <TExpression,Boundary> |
bucket(TExpression groupBy,
List<Boundary> boundaries) |
Creates a $bucket pipeline stage
|
static <TExpression,TBoundary> |
bucket(TExpression groupBy,
List<TBoundary> boundaries,
BucketOptions options) |
Creates a $bucket pipeline stage
|
static <TExpression> |
bucketAuto(TExpression groupBy,
int buckets) |
Creates a $bucketAuto pipeline stage
|
static <TExpression> |
bucketAuto(TExpression groupBy,
int buckets,
BucketAutoOptions options) |
Creates a $bucketAuto pipeline stage
|
static Bson |
count() |
Creates a $count pipeline stage using the field name "count" to store the result
|
static Bson |
count(String field) |
Creates a $count pipeline stage using the named field to store the result
|
static Bson |
facet(Facet... facets) |
Creates a facet pipeline stage
|
static Bson |
facet(List<Facet> facets) |
Creates a facet pipeline stage
|
static <TExpression> |
graphLookup(String from,
TExpression startWith,
String connectFromField,
String connectToField,
String as) |
Creates a graphLookup pipeline stage for the specified filter
|
static <TExpression> |
graphLookup(String from,
TExpression startWith,
String connectFromField,
String connectToField,
String as,
GraphLookupOptions options) |
Creates a graphLookup pipeline stage for the specified filter
|
static <TExpression> |
group(TExpression id,
BsonField... fieldAccumulators) |
Creates a $group pipeline stage for the specified filter
|
static <TExpression> |
group(TExpression id,
List<BsonField> fieldAccumulators) |
Creates a $group pipeline stage for the specified filter
|
static Bson |
limit(int limit) |
Creates a $limit pipeline stage for the specified filter
|
static Bson |
lookup(String from,
String localField,
String foreignField,
String as) |
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
|
static Bson |
lookup(String from,
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
|
static Bson |
lookup(String from,
List<Variable<?>> 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
|
static Bson |
match(Bson filter) |
Creates a $match pipeline stage for the specified filter
|
static Bson |
out(String collectionName) |
Creates a $out pipeline stage for the specified filter
|
static Bson |
project(Bson projection) |
Creates a $project pipeline stage for the specified projection
|
static <TExpression> |
replaceRoot(TExpression value) |
Creates a $replaceRoot pipeline stage
|
static Bson |
sample(int size) |
Creates a $sample pipeline stage with the specified sample size
|
static Bson |
skip(int skip) |
Creates a $skip pipeline stage
|
static Bson |
sort(Bson sort) |
Creates a $sort pipeline stage for the specified sort specification
|
static <TExpression> |
sortByCount(TExpression filter) |
Creates a $sortByCount pipeline stage for the specified filter
|
static Bson |
unwind(String fieldName) |
Creates a $unwind pipeline stage for the specified field name, which must be prefixed by a
'$' sign. |
static Bson |
unwind(String fieldName,
UnwindOptions unwindOptions) |
Creates a $unwind pipeline stage for the specified field name, which must be prefixed by a
'$' sign. |
public static Bson addFields(Field<?>... fields)
fields
- the fields to addpublic static Bson addFields(List<Field<?>> fields)
fields
- the fields to addpublic static <TExpression,Boundary> Bson bucket(TExpression groupBy, List<Boundary> boundaries)
public static <TExpression,TBoundary> Bson bucket(TExpression groupBy, List<TBoundary> boundaries, BucketOptions options)
TExpression
- the groupBy expression typeTBoundary
- the boundary typegroupBy
- the criteria to group Byboundaries
- the boundaries of the bucketsoptions
- the optional values for the $bucket stagepublic static <TExpression> Bson bucketAuto(TExpression groupBy, int buckets)
TExpression
- the groupBy expression typegroupBy
- the criteria to group Bybuckets
- the number of the bucketspublic static <TExpression> Bson bucketAuto(TExpression groupBy, int buckets, BucketAutoOptions options)
TExpression
- the groupBy expression typegroupBy
- the criteria to group Bybuckets
- the number of the bucketsoptions
- the optional values for the $bucketAuto stagepublic static Bson count()
public static Bson count(String field)
public static Bson match(Bson filter)
public static Bson project(Bson projection)
projection
- the projectionProjections
public static Bson sort(Bson sort)
public static <TExpression> Bson sortByCount(TExpression filter)
TExpression
- the expression typefilter
- the filter specificationpublic static Bson skip(int skip)
skip
- the number of documents to skippublic static Bson limit(int limit)
limit
- the limitpublic static Bson lookup(String from, String localField, String foreignField, String as)
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.public static Bson lookup(String from, List<? extends Bson> pipeline, String as)
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.public static Bson lookup(String from, @Nullable List<Variable<?>> let, List<? extends Bson> pipeline, String as)
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.public static <TExpression> Bson graphLookup(String from, TExpression startWith, String connectFromField, String connectToField, String as)
TExpression
- the expression typefrom
- the collection to querystartWith
- the expression to start the graph lookup withconnectFromField
- the from fieldconnectToField
- the to fieldas
- name of field in output documentpublic static <TExpression> Bson graphLookup(String from, TExpression startWith, String connectFromField, String connectToField, String as, GraphLookupOptions options)
TExpression
- the expression typefrom
- 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 graphLookuppublic static <TExpression> Bson group(TExpression id, BsonField... fieldAccumulators)
TExpression
- the expression typeid
- the id expression for the groupfieldAccumulators
- zero or more field accumulator pairspublic static <TExpression> Bson group(TExpression id, List<BsonField> fieldAccumulators)
TExpression
- the expression typeid
- the id expression for the groupfieldAccumulators
- zero or more field accumulator pairspublic static Bson unwind(String fieldName)
'$'
sign.fieldName
- the field name, prefixed by a '$' sign
public static Bson unwind(String fieldName, UnwindOptions unwindOptions)
'$'
sign.public static Bson out(String collectionName)
public static <TExpression> Bson replaceRoot(TExpression value)
TExpression
- the new root typevalue
- the new root value