KtMongo: MongoDB driver for Kotlin • Coroutines/opensavvy.ktmongo.coroutines/CoroutineMongoAggregationPipeline

CoroutineMongoAggregationPipeline

interface CoroutineMongoAggregationPipeline<Document : Any> : MongoAggregationPipeline<Document> (source)

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.

countTo

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

abstract override fun <Out : Any> countTo(field: Field<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: GroupStageOperators<Document, Out>.() -> Unit): CoroutineMongoAggregationPipeline<Out>

limit

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

abstract override fun limit(amount: Long): 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: Int): CoroutineMongoAggregationPipeline<Document>

abstract override fun skip(amount: Long): 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)