object BSONAggregationFramework extends AggregationFramework[BSONSerializationPack.type]
- Annotations
- @deprecated
- Deprecated
(Since version 0.16.0) Internal: will be made private
- Alphabetic
- By Inheritance
- BSONAggregationFramework
- AggregationFramework
- AggregationPipeline
- SortAggregation
- SliceAggregation
- GroupAggregation
- ImplicitCommandHelpers
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- class AddFields extends PipelineOperator with Product1[P.Document] with Serializable
$addFields stage.
$addFields stage.
- Definition Classes
- AggregationFramework
- Since
MongoDB 3.4
- class Bucket extends PipelineOperator with Product4[P.Value, Seq[P.Value], String, Seq[(String, GroupFunction)]]
$bucket aggregation stage.
$bucket aggregation stage.
- Definition Classes
- AggregationFramework
- class BucketAuto extends PipelineOperator with Product4[P.Value, Int, Option[String], Seq[(String, GroupFunction)]] with Serializable
$bucket aggregation stage.
$bucket aggregation stage.
- Definition Classes
- AggregationFramework
- Since
MongoDB 3.4 Categorizes incoming documents into a specific number of groups, called buckets, based on a specified expression. Bucket boundaries are automatically determined in an attempt to evenly distribute the documents into the specified number of buckets. Document fields identifier must be prefixed with
$.
- final class ChangeStream extends PipelineOperator
Low level pipeline operator which allows to open a tailable cursor against subsequent change events of a given collection.
Low level pipeline operator which allows to open a tailable cursor against subsequent change events of a given collection.
For common use-cases, you might prefer to use the
watchoperator on a collection.Note: the target mongo instance MUST be a replica-set (even in the case of a single node deployement).
- Definition Classes
- AggregationFramework
- Since
MongoDB 3.6
- class CollStats extends PipelineOperator with Product3[Boolean, Option[Double], Boolean] with Serializable
$collStats aggregation stage.
$collStats aggregation stage.
- Definition Classes
- AggregationFramework
- class Count extends PipelineOperator with Product1[String] with Serializable
$count of the number of documents input.
$count of the number of documents input.
- Definition Classes
- AggregationFramework
- Since
MongoDB 3.4
- class CurrentOp extends PipelineOperator with Product5[Boolean, Boolean, Boolean, Boolean, Boolean]
- Definition Classes
- AggregationFramework
- Since
MongoDB 3.6
- class Facet extends PipelineOperator with Product1[Iterable[(String, Pipeline)]] with Serializable
Processes multiple aggregation pipelines within a single stage on the same set of input documents.
Processes multiple aggregation pipelines within a single stage on the same set of input documents.
Each sub-pipeline has its own field in the output document where its results are stored as an array of documents.
- Definition Classes
- AggregationFramework
- See also
https://docs.mongodb.com/manual/reference/operator/aggregation/facet/
- class GeoNear extends PipelineOperator with Product with Serializable
$geoNear aggregation stage, that outputs documents in order of nearest to farthest from a specified point.
$geoNear aggregation stage, that outputs documents in order of nearest to farthest from a specified point.
- Definition Classes
- AggregationFramework
- class GraphLookup extends PipelineOperator with Product8[String, P.Value, String, String, String, Option[Int], Option[String], Option[P.Value]] with Serializable
The $graphLookup aggregation stage.
The $graphLookup aggregation stage.
- Definition Classes
- AggregationFramework
- Since
MongoDB 3.4
- class Group extends PipelineOperator with Product2[P.Value, Seq[(String, GroupFunction)]] with Serializable
$groups documents together to calculate aggregates on document collections.
$groups documents together to calculate aggregates on document collections. This command aggregates on arbitrary identifiers. Document fields identifier must be prefixed with
$.- Definition Classes
- AggregationFramework
- class GroupField extends PipelineOperator with Product2[String, Seq[(String, GroupFunction)]] with Serializable
$groups documents together to calculate aggregates on document collections.
$groups documents together to calculate aggregates on document collections. This command aggregates on one field.
- Definition Classes
- AggregationFramework
- class GroupMulti extends PipelineOperator with Product2[Seq[(String, String)], Seq[(String, GroupFunction)]] with Serializable
$groups documents together to calculate aggregates on document collections.
$groups documents together to calculate aggregates on document collections. This command aggregates on multiple fields, and they must be named.
- Definition Classes
- AggregationFramework
- class IndexStatAccesses extends Product2[Long, Long] with Serializable
- Definition Classes
- AggregationFramework
- class IndexStatsResult extends Product4[String, P.Document, String, IndexStatAccesses] with Serializable
- Definition Classes
- AggregationFramework
- class Limit extends PipelineOperator with Product1[Int] with Serializable
$limits the number of documents that pass through the stream.
$limits the number of documents that pass through the stream.
- Definition Classes
- AggregationFramework
- class ListLocalSessions extends PipelineOperator
$listLocalSessions aggregation stage.
$listLocalSessions aggregation stage.
- Definition Classes
- AggregationFramework
- Since
MongoDB 3.6
- class ListSessions extends PipelineOperator
$listSessions aggregation stage.
$listSessions aggregation stage.
- Definition Classes
- AggregationFramework
- Since
MongoDB 3.6
- class Lookup extends PipelineOperator with Product4[String, String, String, String] with Serializable
Performs a left outer join to an unsharded collection in the same database to filter in documents from the "joined" collection for processing.
Performs a left outer join to an unsharded collection in the same database to filter in documents from the "joined" collection for processing.
- Definition Classes
- AggregationFramework
- Since
MongoDB 3.2
- class Match extends PipelineOperator with Product1[P.Document] with Serializable
Filters out documents from the stream that do not match the predicate.
Filters out documents from the stream that do not match the predicate.
- Definition Classes
- AggregationFramework
- class Merge extends PipelineOperator with Product6[String, String, Seq[String], Option[String], Option[P.Document], Option[String]] with Serializable
$merge aggregation stage.
$merge aggregation stage.
- Definition Classes
- AggregationFramework
- Since
MongoDB 4.2
- class Out extends PipelineOperator with Product1[String] with Serializable
Takes the documents returned by the aggregation pipeline and writes them to a specified collection
Takes the documents returned by the aggregation pipeline and writes them to a specified collection
- Definition Classes
- AggregationFramework
- class Project extends PipelineOperator with Product1[P.Document] with Serializable
Reshapes a document stream by renaming, adding, or removing fields.
Reshapes a document stream by renaming, adding, or removing fields. Also uses Project to create computed values or sub-objects.
- Definition Classes
- AggregationFramework
- class Redact extends PipelineOperator with Product1[P.Document] with Serializable
Restricts the contents of the documents based on information stored in the documents themselves.
Restricts the contents of the documents based on information stored in the documents themselves. http://docs.mongodb.org/manual/reference/operator/aggregation/redact/#pipe._S_redact Redact
- Definition Classes
- AggregationFramework
- class ReplaceRoot extends PipelineOperator with Product1[P.Document] with Serializable
Promotes a specified document to the top level and replaces all other fields.
Promotes a specified document to the top level and replaces all other fields. The operation replaces all existing fields in the input document, including the _id field. https://docs.mongodb.com/manual/reference/operator/aggregation/replaceRoot
- Definition Classes
- AggregationFramework
- class ReplaceRootField extends PipelineOperator with Product1[String] with Serializable
Promotes a specified document to the top level and replaces all other fields.
Promotes a specified document to the top level and replaces all other fields. The operation replaces all existing fields in the input document, including the _id field. https://docs.mongodb.com/manual/reference/operator/aggregation/replaceRoot
- Definition Classes
- AggregationFramework
- class ReplaceWith extends PipelineOperator with Product1[P.Document] with Serializable
The $replaceWith aggregation stage.
The $replaceWith aggregation stage.
- Definition Classes
- AggregationFramework
- Since
MongoDB 4.2
- class Sample extends PipelineOperator with Product1[Int] with Serializable
$sample aggregation stage, that randomly selects the specified number of documents from its input.
$sample aggregation stage, that randomly selects the specified number of documents from its input.
- Definition Classes
- AggregationFramework
- class Set extends PipelineOperator with Product1[P.Document] with Serializable
$set aggregation stage
$set aggregation stage
- Definition Classes
- AggregationFramework
- class Skip extends PipelineOperator with Product1[Int] with Serializable
$skips over a number of documents before passing all further documents along the stream.
$skips over a number of documents before passing all further documents along the stream.
- Definition Classes
- AggregationFramework
- class Sort extends PipelineOperator with Product1[Seq[SortOrder]] with Serializable
$sorts the stream based on the given fields.
$sorts the stream based on the given fields.
- Definition Classes
- AggregationFramework
- class SortByCount extends PipelineOperator with Product1[P.Value] with Serializable
The $sortByCount aggregation stage.
The $sortByCount aggregation stage.
- Definition Classes
- AggregationFramework
- Since
MongoDB 3.4
- class SortByFieldCount extends PipelineOperator with Product1[String] with Serializable
The $sortByCount aggregation stage.
The $sortByCount aggregation stage.
- Definition Classes
- AggregationFramework
- Since
MongoDB 3.4
- class Unset extends PipelineOperator with Product2[String, Seq[String]] with Serializable
The $unset aggregation stage.
The $unset aggregation stage.
- Definition Classes
- AggregationFramework
- Since
MongoDB 4.2
- class Unwind extends PipelineOperator with Product with Serializable
- Definition Classes
- AggregationFramework
- class UnwindField extends Unwind with Serializable
Turns a document with an array into multiple documents, one document for each element in the array.
Turns a document with an array into multiple documents, one document for each element in the array. http://docs.mongodb.org/manual/reference/aggregation/unwind/#_S_unwind
- Definition Classes
- AggregationFramework
- trait ImplicitlyDocumentProducer extends AnyRef
- Definition Classes
- ImplicitCommandHelpers
- class AddFieldToSet extends AggregationFramework.GroupFunction with Product1[String] with Serializable
The $addToSet group accumulator.
The $addToSet group accumulator.
- Definition Classes
- GroupAggregation
- class AddToSet extends AggregationFramework.GroupFunction with Product1[GroupAggregation.P.Value] with Serializable
The $addToSet group accumulator.
The $addToSet group accumulator.
- Definition Classes
- GroupAggregation
- class Ascending extends AggregationFramework.SortOrder with Product1[String] with Serializable
Ascending sort order
Ascending sort order
- Definition Classes
- SortAggregation
- class Avg extends AggregationFramework.GroupFunction with Product1[GroupAggregation.P.Value] with Serializable
The $avg group accumulator.
The $avg group accumulator.
- Definition Classes
- GroupAggregation
- class AvgField extends AggregationFramework.GroupFunction with Product1[String] with Serializable
The $avg group accumulator.
The $avg group accumulator.
- Definition Classes
- GroupAggregation
- class Descending extends AggregationFramework.SortOrder with Product1[String] with Serializable
Descending sort order
Descending sort order
- Definition Classes
- SortAggregation
- class First extends AggregationFramework.GroupFunction with Product1[GroupAggregation.P.Value] with Serializable
The $field group accumulator.
The $field group accumulator.
- Definition Classes
- GroupAggregation
- class FirstField extends AggregationFramework.GroupFunction with Product1[String] with Serializable
The $field group accumulator.
The $field group accumulator.
- Definition Classes
- GroupAggregation
- sealed trait GroupFunction extends AnyRef
Represents one of the group/accumulator operators, for the
$groupaggregation.Represents one of the group/accumulator operators, for the
$groupaggregation. Operation.- Definition Classes
- GroupAggregation
- See also
https://docs.mongodb.com/manual/reference/operator/aggregation/group/#accumulator-operator
- class Last extends AggregationFramework.GroupFunction with Product1[GroupAggregation.P.Value] with Serializable
The $field group accumulator.
The $field group accumulator.
- Definition Classes
- GroupAggregation
- class LastField extends AggregationFramework.GroupFunction with Product1[String] with Serializable
The $field group accumulator.
The $field group accumulator.
- Definition Classes
- GroupAggregation
- class Max extends AggregationFramework.GroupFunction
The $max group accumulator.
The $max group accumulator.
- Definition Classes
- GroupAggregation
- class MaxField extends AggregationFramework.GroupFunction with Product1[String] with Serializable
The $max group accumulator.
The $max group accumulator.
- Definition Classes
- GroupAggregation
- class MergeObjects extends AggregationFramework.GroupFunction with Product1[GroupAggregation.P.Value] with Serializable
The $mergeObjects group accumulator.
The $mergeObjects group accumulator.
- Definition Classes
- GroupAggregation
- sealed trait MetadataKeyword extends AnyRef
- Definition Classes
- SortAggregation
- class MetadataSort extends AggregationFramework.SortOrder with Product2[String, AggregationFramework.MetadataKeyword] with Serializable
Metadata sort order.
Metadata sort order.
- Definition Classes
- SortAggregation
- class Min extends AggregationFramework.GroupFunction with Product1[GroupAggregation.P.Value] with Serializable
The $min group accumulator.
The $min group accumulator.
- Definition Classes
- GroupAggregation
- class MinField extends AggregationFramework.GroupFunction with Product1[String] with Serializable
The $min group accumulator.
The $min group accumulator.
- Definition Classes
- GroupAggregation
- type Pipeline = (PipelineOperator, List[PipelineOperator])
Aggregation pipeline (with at least one stage operator)
Aggregation pipeline (with at least one stage operator)
- Definition Classes
- AggregationPipeline
- trait PipelineOperator extends AnyRef
One of MongoDBs pipeline operators for aggregation.
One of MongoDBs pipeline operators for aggregation. Sealed as these are defined in the MongoDB specifications, and clients should not have custom operators.
- Definition Classes
- AggregationPipeline
- class Push extends AggregationFramework.GroupFunction with Product1[GroupAggregation.P.Value] with Serializable
The $push group accumulator.
The $push group accumulator.
- Definition Classes
- GroupAggregation
- class PushField extends AggregationFramework.GroupFunction with Product1[String] with Serializable
The $push group accumulator.
The $push group accumulator.
- Definition Classes
- GroupAggregation
- final class Slice extends AggregationFramework.PipelineOperator
Returns a subset of an array.
Returns a subset of an array. https://docs.mongodb.com/manual/reference/operator/aggregation/slice/
- Definition Classes
- SliceAggregation
- sealed trait SortOrder extends AnyRef
Represents that a field should be sorted on, as well as whether it should be ascending or descending.
Represents that a field should be sorted on, as well as whether it should be ascending or descending.
- Definition Classes
- SortAggregation
- class StdDevPop extends AggregationFramework.GroupFunction with Product1[GroupAggregation.P.Value] with Serializable
The $stdDevPop group accumulator.
The $stdDevPop group accumulator.
- Definition Classes
- GroupAggregation
- Since
MongoDB 3.2
- class StdDevPopField extends AggregationFramework.GroupFunction with Product1[String] with Serializable
The $stdDevPop for a single field.
The $stdDevPop for a single field.
- Definition Classes
- GroupAggregation
- Since
MongoDB 3.2
- class StdDevSamp extends AggregationFramework.GroupFunction with Product1[GroupAggregation.P.Value] with Serializable
The $stdDevSamp group accumulator
The $stdDevSamp group accumulator
- Definition Classes
- GroupAggregation
- Since
MongoDB 3.2
- class StdDevSampField extends AggregationFramework.GroupFunction with Product1[String] with Serializable
The $stdDevSamp for a single field
The $stdDevSamp for a single field
- Definition Classes
- GroupAggregation
- Since
MongoDB 3.2
- class Sum extends AggregationFramework.GroupFunction with Product1[GroupAggregation.P.Value] with Serializable
The $sum group accumulator.
The $sum group accumulator.
- Definition Classes
- GroupAggregation
- class SumField extends AggregationFramework.GroupFunction with Product1[String] with Serializable
The $sum group accumulator.
The $sum group accumulator.
- Definition Classes
- GroupAggregation
Deprecated Type Members
- case class Aggregate(pipeline: Seq[AggregationFramework.PipelineOperator], explain: Boolean = false, allowDiskUse: Boolean, cursor: Option[Cursor], wireVersion: MongoWireVersion, bypassDocumentValidation: Boolean, readConcern: Option[ReadConcern]) extends CollectionCommand with CommandWithPack[pack.type] with CommandWithResult[AggregationResult] with Product with Serializable
- pipeline
the sequence of MongoDB aggregation operations
- explain
specifies to return the information on the processing of the pipeline
- allowDiskUse
enables writing to temporary files
- cursor
the cursor object for aggregation
- bypassDocumentValidation
available only if you specify the $out aggregation operator
- readConcern
the read concern
- Definition Classes
- AggregationFramework
- Annotations
- @deprecated
- Deprecated
(Since version 0.12.7) Use
api.collections.Aggregator- Since
MongoDB 3.2
- case class AggregationResult(firstBatch: List[P.Document], cursor: Option[ResultCursor] = None) extends Product with Serializable
- firstBatch
the documents of the first batch
- cursor
the cursor from the result, if any
- Definition Classes
- AggregationFramework
- Annotations
- @deprecated
- Deprecated
(Since version 0.12.7) Use
api.collections.Aggregator- See also
- class Cursor extends Product1[Int]
- Definition Classes
- AggregationFramework
- Annotations
- @deprecated
- Deprecated
(Since version 0.12.7) Use
api.collections.Aggregator
- case class Filter(input: P.Value, as: String, cond: P.Document) extends PipelineOperator with Product with Serializable
The $filter aggregation stage.
The $filter aggregation stage.
- input
the expression that resolves to an array
- as
The variable name for the element in the input array. The as expression accesses each element in the input array by this variable.
- cond
the expression that determines whether to include the element in the resulting array
- Definition Classes
- AggregationFramework
- Annotations
- @deprecated
- Deprecated
(Since version 0.19.4) Not a pipeline operator (stage)
- case class SumValue extends AggregationFramework.GroupFunction with Product with Serializable
- Definition Classes
- GroupAggregation
- Annotations
- @deprecated
- Deprecated
(Since version 0.12.0) Use
SumAll
Value Members
- object AddFields extends AbstractFunction1[P.Document, AddFields] with Serializable
- Definition Classes
- AggregationFramework
- object Bucket
- Definition Classes
- AggregationFramework
- object BucketAuto extends Serializable
- Definition Classes
- AggregationFramework
- object CollStats extends AbstractFunction3[Boolean, Option[Double], Boolean, CollStats] with Serializable
- Definition Classes
- AggregationFramework
- object Count extends AbstractFunction1[String, Count] with Serializable
- Definition Classes
- AggregationFramework
- object CurrentOp extends AbstractFunction5[Boolean, Boolean, Boolean, Boolean, Boolean, CurrentOp]
- Definition Classes
- AggregationFramework
- object Cursor extends AbstractFunction1[Int, Cursor]
- Definition Classes
- AggregationFramework
- object Facet extends AbstractFunction1[Iterable[(String, Pipeline)], Facet] with Serializable
- Definition Classes
- AggregationFramework
- object Filter extends Serializable
Filter companion
Filter companion
- Definition Classes
- AggregationFramework
- object GeoNear extends Serializable
- Definition Classes
- AggregationFramework
- object GraphLookup extends AbstractFunction8[String, P.Value, String, String, String, Option[Int], Option[String], Option[P.Value], GraphLookup] with Serializable
- Definition Classes
- AggregationFramework
- object Group extends Serializable
- Definition Classes
- AggregationFramework
- object GroupField extends Serializable
- Definition Classes
- AggregationFramework
- object GroupMulti extends Serializable
- Definition Classes
- AggregationFramework
- object IndexStatAccesses extends AbstractFunction2[Long, Long, IndexStatAccesses] with Serializable
- Definition Classes
- AggregationFramework
- object IndexStats extends PipelineOperator with Product with Serializable
$indexStats aggregation stage.
$indexStats aggregation stage.
- Definition Classes
- AggregationFramework
- Since
MongoDB 3.2
- object IndexStatsResult extends AbstractFunction4[String, P.Document, String, IndexStatAccesses, IndexStatsResult] with Serializable
- Definition Classes
- AggregationFramework
- object Limit extends AbstractFunction1[Int, Limit] with Serializable
- Definition Classes
- AggregationFramework
- object ListLocalSessions extends AbstractFunction1[P.Document, ListLocalSessions]
- Definition Classes
- AggregationFramework
- object ListSessions extends AbstractFunction1[P.Document, ListSessions]
- Definition Classes
- AggregationFramework
- object Lookup extends AbstractFunction4[String, String, String, String, Lookup] with Serializable
- Definition Classes
- AggregationFramework
- object Match extends AbstractFunction1[P.Document, Match] with Serializable
- Definition Classes
- AggregationFramework
- object Merge extends AbstractFunction6[String, String, Seq[String], Option[String], Option[P.Document], Option[String], Merge] with Serializable
- Definition Classes
- AggregationFramework
- object Out extends AbstractFunction1[String, Out] with Serializable
- Definition Classes
- AggregationFramework
- object PlanCacheStats extends PipelineOperator with Product with Serializable
$planCacheStats aggregation stage.
$planCacheStats aggregation stage.
- Definition Classes
- AggregationFramework
- Since
MongoDB 4.2
- object Project extends AbstractFunction1[P.Document, Project] with Serializable
- Definition Classes
- AggregationFramework
- object Redact extends AbstractFunction1[P.Document, Redact] with Serializable
- Definition Classes
- AggregationFramework
- object ReplaceRoot extends AbstractFunction1[P.Document, ReplaceRoot] with Serializable
- Definition Classes
- AggregationFramework
- object ReplaceRootField extends AbstractFunction1[String, ReplaceRootField] with Serializable
- Definition Classes
- AggregationFramework
- object ReplaceWith extends AbstractFunction1[P.Document, ReplaceWith] with Serializable
- Definition Classes
- AggregationFramework
- object Sample extends AbstractFunction1[Int, Sample] with Serializable
- Definition Classes
- AggregationFramework
- object Set extends AbstractFunction1[P.Document, Set] with Serializable
- Definition Classes
- AggregationFramework
- object Skip extends AbstractFunction1[Int, Skip] with Serializable
- Definition Classes
- AggregationFramework
- object Sort extends Serializable
- Definition Classes
- AggregationFramework
- object SortByCount extends AbstractFunction1[P.Value, SortByCount] with Serializable
- Definition Classes
- AggregationFramework
- object SortByFieldCount extends AbstractFunction1[String, SortByFieldCount] with Serializable
- Definition Classes
- AggregationFramework
- object Unset extends AbstractFunction2[String, Seq[String], Unset] with Serializable
- Definition Classes
- AggregationFramework
- object Unwind extends Serializable
- Definition Classes
- AggregationFramework
- object UnwindField extends AbstractFunction1[String, UnwindField] with Serializable
- Definition Classes
- AggregationFramework
- object ImplicitlyDocumentProducer
- Definition Classes
- ImplicitCommandHelpers
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##(): Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- final lazy val builder: Builder[pack.type]
- Attributes
- protected
- Definition Classes
- AggregationFramework
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- val pack: BSONSerializationPack.type
- Definition Classes
- BSONAggregationFramework → AggregationPipeline → ImplicitCommandHelpers
- final def pipe(name: String, arg: Value): Document
- Attributes
- protected
- Definition Classes
- AggregationFramework
- Annotations
- @inline()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- object AddFieldToSet extends AbstractFunction1[String, AggregationFramework.AddFieldToSet] with Serializable
- Definition Classes
- GroupAggregation
- object AddToSet extends AbstractFunction1[GroupAggregation.P.Value, AggregationFramework.AddToSet] with Serializable
- Definition Classes
- GroupAggregation
- object Ascending extends AbstractFunction1[String, AggregationFramework.Ascending] with Serializable
- Definition Classes
- SortAggregation
- object Avg extends AbstractFunction1[GroupAggregation.P.Value, AggregationFramework.Avg] with Serializable
- Definition Classes
- GroupAggregation
- object AvgField extends AbstractFunction1[String, AggregationFramework.AvgField] with Serializable
- Definition Classes
- GroupAggregation
- object Descending extends AbstractFunction1[String, AggregationFramework.Descending] with Serializable
- Definition Classes
- SortAggregation
- object First extends AbstractFunction1[GroupAggregation.P.Value, AggregationFramework.First] with Serializable
- Definition Classes
- GroupAggregation
- object FirstField extends AbstractFunction1[String, AggregationFramework.FirstField] with Serializable
- Definition Classes
- GroupAggregation
- object GroupFunction
Factory to declare custom call to a group function.
Factory to declare custom call to a group function.
- Definition Classes
- GroupAggregation
- object Last extends AbstractFunction1[GroupAggregation.P.Value, AggregationFramework.Last] with Serializable
- Definition Classes
- GroupAggregation
- object LastField extends AbstractFunction1[String, AggregationFramework.LastField] with Serializable
- Definition Classes
- GroupAggregation
- object Max extends AbstractFunction1[GroupAggregation.P.Value, AggregationFramework.Max]
- Definition Classes
- GroupAggregation
- object MaxField extends AbstractFunction1[String, AggregationFramework.MaxField] with Serializable
- Definition Classes
- GroupAggregation
- object MergeObjects extends AbstractFunction1[GroupAggregation.P.Value, AggregationFramework.MergeObjects] with Serializable
- Definition Classes
- GroupAggregation
- object MetadataSort extends AbstractFunction2[String, AggregationFramework.MetadataKeyword, AggregationFramework.MetadataSort] with Serializable
- Definition Classes
- SortAggregation
- object Min extends AbstractFunction1[GroupAggregation.P.Value, AggregationFramework.Min] with Serializable
- Definition Classes
- GroupAggregation
- object MinField extends AbstractFunction1[String, AggregationFramework.MinField] with Serializable
- Definition Classes
- GroupAggregation
- object PipelineOperator
Only for advanced user: Factory for stage not already provided in the API.
Only for advanced user: Factory for stage not already provided in the API.
For example for
{ $sample: { size: 2 } }import scala.concurrent.ExecutionContext import reactivemongo.api.bson.{ BSONDocument, BSONInteger, BSONString } import reactivemongo.api.bson.collection.BSONCollection def foo(coll: BSONCollection)(implicit ec: ExecutionContext) = coll.aggregateWith[BSONDocument]() { agg => import agg.PipelineOperator val stage = PipelineOperator(BSONDocument( f"$$sample" -> BSONDocument("size" -> 2))) stage -> List.empty }
- Definition Classes
- AggregationPipeline
- object Push extends AbstractFunction1[GroupAggregation.P.Value, AggregationFramework.Push] with Serializable
- Definition Classes
- GroupAggregation
- object PushField extends AbstractFunction1[String, AggregationFramework.PushField] with Serializable
- Definition Classes
- GroupAggregation
- object Slice
import scala.concurrent.ExecutionContext import reactivemongo.api.bson.{ BSONDocument, BSONInteger, BSONString } import reactivemongo.api.bson.collection.BSONCollection def foo(coll: BSONCollection)(implicit ec: ExecutionContext) = { coll.aggregateWith[BSONDocument]() { agg => import agg.{ Project, Slice } // Define the pipeline stages Project(BSONDocument( "name" -> 1, "favorites" -> Slice( array = BSONString(f"$$favorites"), n = BSONInteger(3)).makePipe)) -> List.empty } }
- Definition Classes
- SliceAggregation
- object StdDevPop extends AbstractFunction1[GroupAggregation.P.Value, AggregationFramework.StdDevPop] with Serializable
- Definition Classes
- GroupAggregation
- object StdDevPopField extends AbstractFunction1[String, AggregationFramework.StdDevPopField] with Serializable
- Definition Classes
- GroupAggregation
- object StdDevSamp extends AbstractFunction1[GroupAggregation.P.Value, AggregationFramework.StdDevSamp] with Serializable
- Definition Classes
- GroupAggregation
- object StdDevSampField extends AbstractFunction1[String, AggregationFramework.StdDevSampField] with Serializable
- Definition Classes
- GroupAggregation
- object Sum extends AbstractFunction1[GroupAggregation.P.Value, AggregationFramework.Sum] with Serializable
- Definition Classes
- GroupAggregation
- object SumAll extends AggregationFramework.GroupFunction with Product with Serializable
The
$sum: 1group accumulator.The
$sum: 1group accumulator.- Definition Classes
- GroupAggregation
- object SumField extends AbstractFunction1[String, AggregationFramework.SumField] with Serializable
- Definition Classes
- GroupAggregation
- object TextScore extends AggregationFramework.MetadataKeyword with Product with Serializable
References the score associated with the corresponding
$textquery for each matching document.References the score associated with the corresponding
$textquery for each matching document.- Definition Classes
- SortAggregation