[
https://issues.apache.org/jira/browse/SPARK-43995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Venkata Sai Akhil Gudesa updated SPARK-43995:
---------------------------------------------
Description:
Reference file -
[https://github.com/apache/spark/blob/master/sql/core/src/main/scala/org/apache/spark/sql/UDFRegistration.scala]
API to be implemented:
*
{noformat}
def register(name: String, udf: UserDefinedFunction):
UserDefinedFunction{noformat}
*
**
[Reference|https://github.com/apache/spark/blob/master/sql/core/src/main/scala/org/apache/spark/sql/UDFRegistration.scala#L112-L123]
*
{noformat}
def register[RT: TypeTag](name: String, func: Function0[RT]):
UserDefinedFunction{noformat}
*
** From [0 to 22
arguments|https://github.com/apache/spark/blob/master/sql/core/src/main/scala/org/apache/spark/sql/UDFRegistration.scala#L125-L642]
*
{noformat}
def register(name: String, f: UDF0[_], returnType: DataType): Unit{noformat}
*
** From [0 to 22
arguments|https://github.com/apache/spark/blob/master/sql/core/src/main/scala/org/apache/spark/sql/UDFRegistration.scala#L735-L1076]
We currently do not support UDAFs so the relevant UDAF APIs may be skipped as
well as the python/pyspark (in the context of the scala client) related APIs.
was:
Reference file -
[https://github.com/apache/spark/blob/master/sql/core/src/main/scala/org/apache/spark/sql/UDFRegistration.scala]
API to be implemented:
* def register(name: String, udf: UserDefinedFunction): UserDefinedFunction
**
[Reference|https://github.com/apache/spark/blob/master/sql/core/src/main/scala/org/apache/spark/sql/UDFRegistration.scala#L112-L123]
* def register[RT: TypeTag](name: String, func: Function0[RT]):
UserDefinedFunction
** From [0 to 22
arguments|https://github.com/apache/spark/blob/master/sql/core/src/main/scala/org/apache/spark/sql/UDFRegistration.scala#L125-L642]
* def register(name: String, f: UDF0[_], returnType: DataType): Unit
** From [0 to 22
arguments|https://github.com/apache/spark/blob/master/sql/core/src/main/scala/org/apache/spark/sql/UDFRegistration.scala#L735-L1076]
We currently do not support UDAFs so the relevant UDAF APIs may be skipped as
well as the python/pyspark (in the context of the scala client) related APIs.
> Implement UDFRegistration
> -------------------------
>
> Key: SPARK-43995
> URL: https://issues.apache.org/jira/browse/SPARK-43995
> Project: Spark
> Issue Type: New Feature
> Components: Connect
> Affects Versions: 3.5.0
> Reporter: Venkata Sai Akhil Gudesa
> Priority: Major
>
> Reference file -
> [https://github.com/apache/spark/blob/master/sql/core/src/main/scala/org/apache/spark/sql/UDFRegistration.scala]
> API to be implemented:
> *
> {noformat}
> def register(name: String, udf: UserDefinedFunction):
> UserDefinedFunction{noformat}
> *
> **
> [Reference|https://github.com/apache/spark/blob/master/sql/core/src/main/scala/org/apache/spark/sql/UDFRegistration.scala#L112-L123]
> *
> {noformat}
> def register[RT: TypeTag](name: String, func: Function0[RT]):
> UserDefinedFunction{noformat}
> *
> ** From [0 to 22
> arguments|https://github.com/apache/spark/blob/master/sql/core/src/main/scala/org/apache/spark/sql/UDFRegistration.scala#L125-L642]
> *
> {noformat}
> def register(name: String, f: UDF0[_], returnType: DataType): Unit{noformat}
> *
> ** From [0 to 22
> arguments|https://github.com/apache/spark/blob/master/sql/core/src/main/scala/org/apache/spark/sql/UDFRegistration.scala#L735-L1076]
>
> We currently do not support UDAFs so the relevant UDAF APIs may be skipped as
> well as the python/pyspark (in the context of the scala client) related APIs.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org
For additional commands, e-mail: issues-h...@spark.apache.org
