modelql-core/org.modelix.modelql.core/UnboundQuery

UnboundQuery

abstract class UnboundQuery<In, AggregationOut, ElementOut>(val inputStep: QueryInput<In>, outputStep_: IProducingStep<ElementOut>, val reference: QueryReference<UnboundQuery<In, AggregationOut, ElementOut>>, val sharedSteps: List<SharedStep<*>>) : IUnboundQuery<In, AggregationOut, ElementOut>

Inheritors

MonoUnboundQuery

FluxUnboundQuery

Constructors

constructor(inputStep: QueryInput<In>, outputStep_: IProducingStep<ElementOut>, reference: QueryReference<UnboundQuery<In, AggregationOut, ElementOut>>, sharedSteps: List<SharedStep<*>>)

Types

object Companion

Properties

val inputStep: QueryInput<In>

open val outputStep: IProducingStep<ElementOut>

open override val reference: QueryReference<UnboundQuery<In, AggregationOut, ElementOut>>

val sharedSteps: List<SharedStep<*>>

Functions

open fun asFlow(evaluationContext: QueryEvaluationContext, input: IStepOutput<In>): StepFlow<ElementOut>

open override fun asFlow(evaluationContext: QueryEvaluationContext, input: StepFlow<In>): StepFlow<ElementOut>

abstract fun bind(executor: IQueryExecutor<In>): IQuery<AggregationOut, ElementOut>

open override fun canBeEmpty(): Boolean

fun <In, Out, ElementOut> IUnboundQuery<In, Out, ElementOut>.castToInstance(): UnboundQuery<In, Out, ElementOut>

createDescriptor

fun createDescriptor(): QueryGraphDescriptor

abstract suspend fun execute(evaluationContext: QueryEvaluationContext, input: IStepOutput<In>): IStepOutput<AggregationOut>

getAggregationOutputSerializer

abstract fun getAggregationOutputSerializer(serializationContext: SerializationContext): KSerializer<out IStepOutput<AggregationOut>>

fun getAllSteps(): Set<IStep>

getElementOutputSerializer

abstract fun getElementOutputSerializer(serializationContext: SerializationContext): KSerializer<out IStepOutput<ElementOut>>

fun getOwnSteps(): List<IStep>

requiresWriteAccess

open override fun requiresWriteAccess(): Boolean

open override fun toString(): String