Hi
Can you try below :
We are registering using spark.sql.function.udf :
def *myUDF*(wgts: *Int*, amnt: *Float*) = (wgts*amnt)/100.asInstanceOf[
Float]
val *myUdf* = udf(myUDF(_:int,_:Float))
>
Now you can invoke the function directly in spark sql or outside.
Thanks,
Paras Sachdeva
On
Hi Daniel,
Would you possibly be able to share the snipped to code you have used ?
Thank you.
On Wed, Apr 27, 2016 at 3:13 PM, Daniel Haviv <
daniel.ha...@veracity-group.com> wrote:
> Hi Benjamin,
> Yes it should work.
>
> Let me know if you need further assistance I might be able to get the
