JoinStep

Constructors

Link copied to clipboard
constructor()

Types

Link copied to clipboard
@Serializable
@SerialName(value = "join")
class Descriptor : CoreStepDescriptor

Properties

Link copied to clipboard
open override val owner: QueryReference<*>

Functions

Link copied to clipboard
open override fun addConsumer(consumer: IConsumingStep<E>)
Link copied to clipboard
open override fun addProducer(producer: IProducingStep<E>)
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
fun <In, K, V> IFluxStep<In>.associate(keySelector: (IMonoStep<In>) -> IMonoStep<K>, valueSelector: (IMonoStep<In>) -> IMonoStep<V>): IMonoStep<Map<K, V>>
Link copied to clipboard
fun <K, V> IFluxStep<V>.associateBy(keySelector: (IMonoStep<V>) -> IMonoStep<K>): IMonoStep<Map<K, V>>
Link copied to clipboard
fun <K, V> IFluxStep<K>.associateWith(valueSelector: (IMonoStep<K>) -> IMonoStep<V>): IMonoStep<Map<K, V>>
Link copied to clipboard
@JvmName(name = "asStringNullable")
fun IFluxStep<Any?>.asString(): IFluxStep<String?>
Link copied to clipboard
open override fun canBeEmpty(): Boolean
Link copied to clipboard
open override fun canBeMultiple(): Boolean
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open override fun createFlow(context: IFlowInstantiationContext): StepFlow<E>
Link copied to clipboard
fun <T> IFluxStep<T>.drop(count: Int): IFluxStep<T>
Link copied to clipboard
open fun evaluateStatically(): E
Link copied to clipboard
fun <In, Out> IFluxStep<In>.executeLocal(body: (In) -> Out): IFluxStep<Out>
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open override fun getConsumers(): List<IConsumingStep<E>>
Link copied to clipboard
open override fun getOutputSerializer(serializationContext: SerializationContext): KSerializer<out IStepOutput<E>>
Link copied to clipboard
open override fun getProducers(): List<IProducingStep<E>>
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
@JvmName(name = "ifEmpty_flux_mono")
fun <In : Out, Out> IFluxStep<In>.ifEmpty(alternative: () -> IMonoStep<Out>): IFluxStep<Out>
Link copied to clipboard
@JvmName(name = "ifEmpty_flux_flux")
fun <In : Out, Out> IFluxStep<In>.ifEmptyFlux(alternative: () -> IFluxStep<Out>): IFluxStep<Out>
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
fun <In, Out> IFluxStep<In>.mapLocal(body: (In) -> Out): IFluxStep<Out>
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
fun <T> IFluxStep<T>.print(prefix: String = ""): IFluxStep<T>
Link copied to clipboard
open override fun requiresSingularQueryInput(): Boolean
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
fun <T> IFluxStep<T>.take(count: Int): IFluxStep<T>
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
fun <K, V> IFluxStep<IZip2Output<*, K, V>>.toMap(): IMonoStep<Map<K, V>>
Link copied to clipboard
Link copied to clipboard
open override fun toString(): String
Link copied to clipboard
open fun validate()
Link copied to clipboard
Link copied to clipboard