KtMongo: MongoDB driver for Kotlin • Synchronous/opensavvy.ktmongo.sync/MongoAggregationPipeline

MongoAggregationPipeline

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

Properties

val chain: PipelineChainLink

open override val context: BsonContext

Functions

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

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

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)

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

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

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

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

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

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

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

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

@DangerousMongoApi

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

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

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

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

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

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

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

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

override fun toString(): String

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

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

@DangerousMongoApi

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

override fun writeTo(writer: BsonValueWriter)