org.apache.paimon.spark

Class PaimonSparkScalarFunction

java.lang.Object

org.apache.paimon.spark.PaimonSparkScalarFunction

All Implemented Interfaces:

Serializable, org.apache.spark.sql.connector.catalog.functions.BoundFunction, org.apache.spark.sql.connector.catalog.functions.Function, org.apache.spark.sql.connector.catalog.functions.ScalarFunction<Object>

public class PaimonSparkScalarFunction
extends Object
implements org.apache.spark.sql.connector.catalog.functions.ScalarFunction<Object>, Serializable

Scalar function for Spark.

See Also:

Serialized Form

Field Summary

Fields inherited from interface org.apache.spark.sql.connector.catalog.functions.ScalarFunction

MAGIC_METHOD_NAME

Constructor Summary

Constructors

Constructor and Description
PaimonSparkScalarFunction(String functionName, List<org.apache.spark.sql.types.DataType> inputTypes, org.apache.spark.sql.types.DataType resultType, String javaType, String lambdaExpression)

Method Summary

Modifier and Type	Method and Description
String	canonicalName()
org.apache.spark.sql.types.DataType[]	inputTypes()
String	name()
Object	produceResult(org.apache.spark.sql.catalyst.InternalRow input)
org.apache.spark.sql.types.DataType	resultType()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.spark.sql.connector.catalog.functions.BoundFunction

isDeterministic, isResultNullable

Constructor Detail

PaimonSparkScalarFunction

public PaimonSparkScalarFunction(String functionName,
                                 List<org.apache.spark.sql.types.DataType> inputTypes,
                                 org.apache.spark.sql.types.DataType resultType,
                                 String javaType,
                                 String lambdaExpression)

Method Detail

inputTypes

public org.apache.spark.sql.types.DataType[] inputTypes()

Specified by:

inputTypes in interface org.apache.spark.sql.connector.catalog.functions.BoundFunction

resultType

public org.apache.spark.sql.types.DataType resultType()

Specified by:

resultType in interface org.apache.spark.sql.connector.catalog.functions.BoundFunction

produceResult

public Object produceResult(org.apache.spark.sql.catalyst.InternalRow input)

Specified by:

produceResult in interface org.apache.spark.sql.connector.catalog.functions.ScalarFunction<Object>

name

public String name()

Specified by:

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

canonicalName

public String canonicalName()

Specified by:

canonicalName in interface org.apache.spark.sql.connector.catalog.functions.BoundFunction