Re: [Spark Sql/ UDFs] Spark and Hive UDFs parity

2017-06-18 Thread Yong Zhang
[Spark Sql/ UDFs] Spark and Hive UDFs parity Thanks Georg. But I'm not sure how mapPartitions is relevant here. Can you elaborate? On Thu, Jun 15, 2017 at 4:18 AM, Georg Heiler <georg.kf.hei...@gmail.com<mailto:georg.kf.hei...@gmail.com>> wrote: What about using map partitions

Re: [Spark Sql/ UDFs] Spark and Hive UDFs parity

2017-06-16 Thread Georg Heiler
gt;>> which a lot of our users use. We have now a lot of UDFs in Hive which make >>> use of these methods. We plan to move to UDFs to Spark UDFs but are being >>> limited by not having similar lifecycle methods. >>>Are there plans to address these? Or do people

Re: [Spark Sql/ UDFs] Spark and Hive UDFs parity

2017-06-16 Thread RD
ch a lot of our users use. We have now a lot of UDFs in Hive which make >> use of these methods. We plan to move to UDFs to Spark UDFs but are being >> limited by not having similar lifecycle methods. >>Are there plans to address these? Or do people usually adopt some sort

Re: [Spark Sql/ UDFs] Spark and Hive UDFs parity

2017-06-15 Thread Georg Heiler
ere plans to address these? Or do people usually adopt some sort > of workaround? > >If we directly use the Hive UDFs in Spark we pay a performance > penalty. I think Spark anyways does a conversion from InternalRow to Row > back to InternalRow for native spark udfs and fo

[Spark Sql/ UDFs] Spark and Hive UDFs parity

2017-06-14 Thread RD
which make use of these methods. We plan to move to UDFs to Spark UDFs but are being limited by not having similar lifecycle methods. Are there plans to address these? Or do people usually adopt some sort of workaround? If we directly use the Hive UDFs in Spark we pay a performance

Hive UDFs

2015-07-07 Thread chrish2312
) as reversedString) Thanks in advance! -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Hive-UDFs-tp23707.html Sent from the Apache Spark User List mailing list archive at Nabble.com

RE: Hive UDFs

2015-07-07 Thread Cheng, Hao
dataframe.limit(1).selectExpr(xxx).collect()? -Original Message- From: chrish2312 [mailto:c...@palantir.com] Sent: Wednesday, July 8, 2015 6:20 AM To: user@spark.apache.org Subject: Hive UDFs I know the typical way to apply a hive UDF to a dataframe is basically something like

Re: Is there a way to access Hive UDFs in a HiveContext?

2015-02-05 Thread jamborta
://apache-spark-user-list.1001560.n3.nabble.com/Is-there-a-way-to-access-Hive-UDFs-in-a-HiveContext-tp21510p21527.html Sent from the Apache Spark User List mailing list archive at Nabble.com. - To unsubscribe, e-mail: user-unsubscr

Is there a way to access Hive UDFs in a HiveContext?

2015-02-04 Thread vishpatel
Version: Spark 1.2 on CDH 5.3. -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Is-there-a-way-to-access-Hive-UDFs-in-a-HiveContext-tp21510.html Sent from the Apache Spark User List mailing list archive at Nabble.com