Konduct/io.github.denofbits.konduct.core/AggregationPipelineImpl

AggregationPipelineImpl

class AggregationPipelineImpl<T : Any>(mongoTemplate: MongoTemplate, collectionName: String, documentType: KClass<T>, stages: MutableList<AggregationOperation>, originalType: KClass<*>? = null) : AggregationPipeline<T>

Constructors

constructor(mongoTemplate: MongoTemplate, collectionName: String, documentType: KClass<T>, stages: MutableList<AggregationOperation>, originalType: KClass<*>? = null)

Functions

addFields

open override fun addFields(block: AddFieldsBuilder<T>.() -> Unit): AggregationPipeline<T>

Performs add fields operations

count

open override fun count(): Long

Execute pipeline and return count of matching documents.

customStage

open override fun customStage(stageName: String, block: CustomStageBuilder.() -> Unit): AggregationPipeline<T>

For building custom stages

facet

open override fun <R : Any> facet(resultType: KClass<R>, block: FacetBuilder<T>.() -> Unit): AggregationPipeline<R>

firstOrNull

open override fun firstOrNull(): T?

Execute pipeline and return first result or null.

group

open override fun group(block: GroupBuilder<T>.() -> Unit): AggregationPipeline<Document>

open override fun <R : Any> group(resultType: KClass<R>, block: GroupBuilder<T>.() -> Unit): AggregationPipeline<R>

Perform grouping operations in pipeline

into

open override fun <R : Any> into(resultType: KClass<R>): AggregationPipeline<R>

limit

open override fun limit(count: Int): AggregationPipeline<T>

Limit to N documents ($limit stage).

match

open override fun match(block: MatchBuilder<T>.() -> Unit): AggregationPipeline<T>

Filter documents ($match stage).

paginate

open override fun paginate(page: Int, pageSize: Int): AggregationPipeline<PagedResult<T>>

Paginate result of previous stages output

skip

open override fun skip(count: Int): AggregationPipeline<T>

Skip N documents ($skip stage).

sort

open override fun sort(block: SortBuilder<T>.() -> Unit): AggregationPipeline<T>

Sort documents ($sort stage).

toAggregation

open override fun toAggregation(): Aggregation

Get raw Spring Data Aggregation for debugging.

toJson

open override fun toJson(): String

Get pipeline as JSON string for debugging.

toList

open override fun toList(): List<T>

Execute pipeline and return all results.