CoroutineMongoAggregationPipeline

interface CoroutineMongoAggregationPipeline<Document : Any> : MongoAggregationPipeline<Document> 

An aggregation pipeline built on top of the official Kotlin driver.

To start a pipeline, call MongoCollection.aggregate.

External resources

• Official documentation

Properties

context

@LowLevelApi
abstract val context: BsonContext

Functions

asIterable

@LowLevelApi
abstract override fun asIterable(type: KType): CoroutineMongoAggregateIterable<Document>

asIterable

inline fun <Document : Any> CoroutineMongoAggregationPipeline<Document>.asIterable(): CoroutineMongoAggregateIterable<Document>

Access the data of this pipeline as a MongoIterable.

The methods of MongoIterable are available directly on this type as extension methods, there is no need to convert to a MongoIterable yourself.

countTo

abstract override fun <Out : Any> countTo(field: Field<Out, Number>): CoroutineMongoAggregationPipeline<Out>

abstract override fun <Out : Any> countTo(field: KProperty1<Out, Number>): CoroutineMongoAggregationPipeline<Out>

embedInLookup

@LowLevelApi
abstract fun embedInLookup(writer: BsonFieldWriter)

embedInUnionWith

@LowLevelApi
abstract fun embedInUnionWith(writer: BsonFieldWriter)

group

abstract override fun <Out : Any> group(block: AccumulationOperators<Document, Out>.() -> Unit): CoroutineMongoAggregationPipeline<Out>

limit

abstract override fun limit(amount: Long): CoroutineMongoAggregationPipeline<Document>

abstract override fun limit(amount: Int): CoroutineMongoAggregationPipeline<Document>

lookup

abstract override fun <ForeignDocument : Any> lookup(block: LookupStageOperators<Document, ForeignDocument>.() -> Unit): CoroutineMongoAggregationPipeline<Document>

match

abstract override fun match(filter: FilterQuery<Document>.() -> Unit): CoroutineMongoAggregationPipeline<Document>

matchExpr

abstract override fun matchExpr(filter: AggregationOperators.() -> Value<Document, Boolean>): CoroutineMongoAggregationPipeline<Document>

project

abstract override fun project(block: ProjectStageOperators<Document>.() -> Unit): CoroutineMongoAggregationPipeline<Document>

reinterpret

@DangerousMongoApi
@LowLevelApi
abstract fun <New : Any> reinterpret(): Pipeline<New>

sample

abstract override fun sample(size: Int): CoroutineMongoAggregationPipeline<Document>

set

abstract override fun set(block: SetStageOperators<Document>.() -> Unit): CoroutineMongoAggregationPipeline<Document>

skip

abstract override fun skip(amount: Long): CoroutineMongoAggregationPipeline<Document>

abstract override fun skip(amount: Int): CoroutineMongoAggregationPipeline<Document>

sort

abstract override fun sort(block: SortOptionDsl<Document>.() -> Unit): CoroutineMongoAggregationPipeline<Document>

toString

abstract override fun toString(): String

unionWith

abstract override fun unionWith(other: HasUnionWithCompatibility<Document>): CoroutineMongoAggregationPipeline<Document>

unset

abstract override fun unset(block: UnsetStageOperators<Document>.() -> Unit): CoroutineMongoAggregationPipeline<Document>

withStage

@DangerousMongoApi
@LowLevelApi
abstract fun withStage(stage: BsonNode): Pipeline<Document>

writeTo

@LowLevelApi
abstract fun writeTo(writer: BsonValueWriter)