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

MongoAggregationPipeline

class MongoAggregationPipeline<Output : Any> : AbstractPipeline<Output> , AggregationPipeline<Output> , LazyMongoIterable<Output> (source)

Properties

chain

@LowLevelApi

val chain: PipelineChainLink

context

@LowLevelApi

open override val context: BsonContext

Functions

asFlow

inline fun <Document : Any> LazyMongoIterable<Document>.asFlow(): Flow<Document>

asIterable

open override fun asIterable(documentType: Class<Output>): MongoIterable<Output>

asIterable

inline fun <Document : Any> LazyMongoIterable<Document>.asIterable(): MongoIterable<Document>

countTo

open fun <Output : Any> countTo(field: KProperty1<Output, Number>): Pipeline<Output>

open fun <Output : Any> countTo(field: Field<Output, Number>): Pipeline<Output>

embedInUnionWith

open override fun embedInUnionWith(writer: BsonFieldWriter)

first

inline suspend fun <Document : Any> LazyMongoIterable<Document>.first(): Document

firstOrNull

inline suspend fun <Document : Any> LazyMongoIterable<Document>.firstOrNull(): Document?

forEach

inline suspend fun <Document : Any> LazyMongoIterable<Document>.forEach(noinline action: suspend (Document) -> Unit)

group

open override fun <Out : Any> group(block: AccumulationOperators<Output, Out>.() -> Unit): MongoAggregationPipeline<Out>

limit

open override fun limit(amount: Int): MongoAggregationPipeline<Output>

open override fun limit(amount: Long): MongoAggregationPipeline<Output>

match

open override fun match(filter: FilterQuery<Output>.() -> Unit): MongoAggregationPipeline<Output>

project

open override fun project(block: ProjectStageOperators<Output>.() -> Unit): MongoAggregationPipeline<Output>

reinterpret

@LowLevelApi

@DangerousMongoApi

open override fun <New : Any> reinterpret(): MongoAggregationPipeline<New>

sample

open override fun sample(size: Int): MongoAggregationPipeline<Output>

set

open override fun set(block: SetStageOperators<Output>.() -> Unit): MongoAggregationPipeline<Output>

skip

open override fun skip(amount: Int): MongoAggregationPipeline<Output>

open override fun skip(amount: Long): MongoAggregationPipeline<Output>

sort

open override fun sort(block: SortOptionDsl<Output>.() -> Unit): MongoAggregationPipeline<Output>

toList

inline suspend fun <Document : Any> LazyMongoIterable<Document>.toList(): List<Document>

toSet

inline suspend fun <Document : Any> LazyMongoIterable<Document>.toSet(): Set<Document>

toString

override fun toString(): String

unionWith

open override fun unionWith(other: HasUnionWithCompatibility<Output>): MongoAggregationPipeline<Output>

unset

open override fun unset(block: UnsetStageOperators<Output>.() -> Unit): MongoAggregationPipeline<Output>

withStage

@LowLevelApi

@DangerousMongoApi

open override fun withStage(stage: BsonNode): MongoAggregationPipeline<Output>

writeTo

@LowLevelApi

override fun writeTo(writer: BsonValueWriter)