kotlin-spark-api_3.3.2_2.13/org.jetbrains.kotlinx.spark.api/NamedUserDefinedFunctionVararg

NamedUserDefinedFunctionVararg

class NamedUserDefinedFunctionVararg<T, R>( val name: String, udf: UserDefinedFunction, encoder: Encoder<R>) : UserDefinedFunctionVararg<T, R> , NamedUserDefinedFunction<R, NamedUserDefinedFunctionVararg<T, R>>

Instance of a UDF with vararg arguments of the same type with name. This UDF can be invoked with (typed) columns in a Dataset.select or selectTyped call. Alternatively it can be registered for SQL calls using register.

Constructors

constructor(name: String, udf: UserDefinedFunction, encoder: Encoder<R>)

Properties

deterministic

open val deterministic: Boolean

Returns true iff the UDF is deterministic, i.e. the UDF produces the same output given the same input.

encoder

abstract val encoder: Encoder<R>

name

open override val name: String

nullable

open val nullable: Boolean

Returns true when the UDF can return a nullable value.

udf

abstract val udf: UserDefinedFunction

Functions

getValue

abstract operator fun getValue(thisRef: Any?, property: KProperty<*>): NamedUserDefinedFunctionVararg<T, R>

Converts this UserDefinedFunction to a NamedUserDefinedFunction.

invoke

operator fun <DsType> invoke(vararg params: TypedColumn<DsType, T>): TypedColumn<DsType, R>

Allows this UDF to be called in typed manner using columns in a Dataset.selectTyped call.

withName

abstract fun withName(name: String): NamedUserDefinedFunctionVararg<T, R>

Converts this UserDefinedFunction to a NamedUserDefinedFunction.

NamedUserDefinedFunctionVararg

See also

Constructors

Properties

Functions