org.apache.paimon.spark

Class LambdaScalarFunction

java.lang.Object

org.apache.paimon.spark.LambdaScalarFunction

All Implemented Interfaces:

Serializable, org.apache.spark.sql.connector.catalog.functions.Function, org.apache.spark.sql.connector.catalog.functions.UnboundFunction

public class LambdaScalarFunction
extends Object
implements org.apache.spark.sql.connector.catalog.functions.UnboundFunction, Serializable

paimon spark java lambda scalar function.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
LambdaScalarFunction(String functionName, org.apache.spark.sql.types.DataType outputType, String javaType, String lambdaExpression)

Method Summary

Modifier and Type	Method and Description
org.apache.spark.sql.connector.catalog.functions.BoundFunction	bind(org.apache.spark.sql.types.StructType inputType)
String	description()
String	name()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LambdaScalarFunction

public LambdaScalarFunction(String functionName,
                            org.apache.spark.sql.types.DataType outputType,
                            String javaType,
                            String lambdaExpression)

Method Detail

bind

public org.apache.spark.sql.connector.catalog.functions.BoundFunction bind(org.apache.spark.sql.types.StructType inputType)

Specified by:

bind in interface org.apache.spark.sql.connector.catalog.functions.UnboundFunction

description

public String description()

Specified by:

description in interface org.apache.spark.sql.connector.catalog.functions.UnboundFunction

name

public String name()

Specified by:

name in interface org.apache.spark.sql.connector.catalog.functions.Function