[jira] [Commented] (SPARK-31945) Make more cache enable for Python UDFs.
[
https://issues.apache.org/jira/browse/SPARK-31945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17129951#comment-17129951
]
Apache Spark commented on SPARK-31945:
--
User 'ueshin' has created a pull request for this issue:
https://github.com/apache/spark/pull/28774
> Make more cache enable for Python UDFs.
> ---
>
> Key: SPARK-31945
> URL: https://issues.apache.org/jira/browse/SPARK-31945
> Project: Spark
> Issue Type: Improvement
> Components: PySpark
>Affects Versions: 3.0.0
>Reporter: Takuya Ueshin
>Priority: Major
>
> Currently the cache manager doesn't use the cache for {{udf}} if the {{udf}}
> is created again even if the functions is the same.
> {code:python}
> >>> func = lambda x: x
> >>> df = spark.range(1)
> >>> df.select(udf(func)("id")).cache()
> >>> df.select(udf(func)("id")).explain()
> == Physical Plan ==
> *(2) Project [pythonUDF0#14 AS (id)#12]
> +- BatchEvalPython [(id#0L)], [pythonUDF0#14]
> +- *(1) Range (0, 1, step=1, splits=12)
> {code}
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
-
To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org
For additional commands, e-mail: issues-h...@spark.apache.org
[jira] [Commented] (SPARK-31945) Make more cache enable for Python UDFs.
[
https://issues.apache.org/jira/browse/SPARK-31945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17129948#comment-17129948
]
Apache Spark commented on SPARK-31945:
--
User 'ueshin' has created a pull request for this issue:
https://github.com/apache/spark/pull/28774
> Make more cache enable for Python UDFs.
> ---
>
> Key: SPARK-31945
> URL: https://issues.apache.org/jira/browse/SPARK-31945
> Project: Spark
> Issue Type: Improvement
> Components: PySpark
>Affects Versions: 3.0.0
>Reporter: Takuya Ueshin
>Priority: Major
>
> Currently the cache manager doesn't use the cache for {{udf}} if the {{udf}}
> is created again even if the functions is the same.
> {code:python}
> >>> func = lambda x: x
> >>> df = spark.range(1)
> >>> df.select(udf(func)("id")).cache()
> >>> df.select(udf(func)("id")).explain()
> == Physical Plan ==
> *(2) Project [pythonUDF0#14 AS (id)#12]
> +- BatchEvalPython [(id#0L)], [pythonUDF0#14]
> +- *(1) Range (0, 1, step=1, splits=12)
> {code}
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
-
To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org
For additional commands, e-mail: issues-h...@spark.apache.org
