Hi,
I am not very sure if SPARK data frames apply to your used case, if it does
please give a try by creating a UDF in Python and check whether you can
call it in Scala or not using select and expr.
Regards,
Gourav Sengupta
On Mon, Jul 16, 2018 at 5:32 AM, Chetan Khatri
wrote:
> Hello Jayant,
Hello Jayant,
Thanks for great OSS Contribution :)
On Thu, Jul 12, 2018 at 1:36 PM, Jayant Shekhar
wrote:
> Hello Chetan,
>
> Sorry missed replying earlier. You can find some sample code here :
>
> http://sparkflows.readthedocs.io/en/latest/user-guide/
> python/pipe-python.html
>
> We will
Hello Chetan,
Sorry missed replying earlier. You can find some sample code here :
http://sparkflows.readthedocs.io/en/latest/user-guide/python/pipe-python.html
We will continue adding more there.
Feel free to ping me directly in case of questions.
Thanks,
Jayant
On Mon, Jul 9, 2018 at 9:56
Hello Jayant,
Thank you so much for suggestion. My view was to use Python function as
transformation which can take couple of column names and return object.
which you explained. would that possible to point me to similiar codebase
example.
Thanks.
On Fri, Jul 6, 2018 at 2:56 AM, Jayant
Hello Chetan,
We have currently done it with .pipe(.py) as Prem suggested.
That passes the RDD as CSV strings to the python script. The python script
can either process it line by line, create the result and return it back.
Or create things like Pandas Dataframe for processing and finally write
Prem sure, Thanks for suggestion.
On Wed, Jul 4, 2018 at 8:38 PM, Prem Sure wrote:
> try .pipe(.py) on RDD
>
> Thanks,
> Prem
>
> On Wed, Jul 4, 2018 at 7:59 PM, Chetan Khatri > wrote:
>
>> Can someone please suggest me , thanks
>>
>> On Tue 3 Jul, 2018, 5:28 PM Chetan Khatri,
>> wrote:
>>
try .pipe(.py) on RDD
Thanks,
Prem
On Wed, Jul 4, 2018 at 7:59 PM, Chetan Khatri
wrote:
> Can someone please suggest me , thanks
>
> On Tue 3 Jul, 2018, 5:28 PM Chetan Khatri,
> wrote:
>
>> Hello Dear Spark User / Dev,
>>
>> I would like to pass Python user defined function to Spark Job
Can someone please suggest me , thanks
On Tue 3 Jul, 2018, 5:28 PM Chetan Khatri,
wrote:
> Hello Dear Spark User / Dev,
>
> I would like to pass Python user defined function to Spark Job developed
> using Scala and return value of that function would be returned to DF /
> Dataset API.
>
> Can
Hello Dear Spark User / Dev,
I would like to pass Python user defined function to Spark Job developed
using Scala and return value of that function would be returned to DF /
Dataset API.
Can someone please guide me, which would be best approach to do this.
Python function would be mostly
