Skip to content

MongoAggregationPipeline

Properties

chain

@LowLevelApi



val chain: PipelineChainLink

context

@LowLevelApi



open override val context: BsonContext

Functions

asIterable

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

asIterable

countTo

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

embedInUnionWith

@LowLevelApi



open override fun embedInUnionWith(writer: BsonFieldWriter)

first

firstOrNull

forEach

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

group

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

limit

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

match

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

project

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: Long): MongoAggregationPipeline<Output>
open override fun skip(amount: Int): MongoAggregationPipeline<Output>

sort

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

toList

toSet

toString

override fun toString(): String

unionWith

unset

withStage

@LowLevelApi



@DangerousMongoApi



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

writeTo

@LowLevelApi



override fun writeTo(writer: BsonValueWriter)