org.thales.punch.pl.plugins.udf.functions

Class StrToArrayDouble

java.lang.Object

org.thales.punch.pl.plugins.udf.functions.StrToArrayDouble

All Implemented Interfaces:

Serializable, org.apache.spark.sql.api.java.UDF1<String,Double[]>

public class StrToArrayDouble
extends Object
implements org.apache.spark.sql.api.java.UDF1<String,Double[]>

This class is intended to be used in a Spark Sql Query statement as a function.
The function name is defined during UDFs registration: org.thales.punch.pml.plugins.sql.UdfRegistration and it should return a DataTypes.createArrayType(DataTypes.DoubleType)

USAGE:

        Take as input a STRING and return a Scala  WrappedArray<Double> object
 

        The input String should be in the following format:  [1.0, 2.0, 5, 6.0]
 

        The result of the above input String should be:
                 WrappedArray(1.0, 2.0, 5, 6.0) of type Double
 

        Example in a query Statement:
 

                 SELECT your_registered_function_name('[1, 2, 3, 4.0]')
 

Author:

jonathan

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
StrToArrayDouble()

Method Summary

Modifier and Type	Method and Description
Double[]	call(String tuple)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StrToArrayDouble

public StrToArrayDouble()

Method Detail

call

public Double[] call(String tuple)
              throws Exception

Specified by:

call in interface org.apache.spark.sql.api.java.UDF1<String,Double[]>

Throws:

Exception