UDFTransformer

class UDFTransformer.UDFTransformer(inputCol=None, inputCols=None, outputCol=None, udf=None)[source]

Bases: mmlspark.Utils.ComplexParamsMixin, pyspark.ml.util.JavaMLReadable, pyspark.ml.util.JavaMLWritable, pyspark.ml.wrapper.JavaTransformer

Parameters:
  • inputCol (str) – The name of the input column (default: )
  • outputCol (str) – The name of the output column
  • udf (object) – User Defined Python Function to be applied to the DF input col
  • udfScala (object) – User Defined Function to be applied to the DF input col
getInputCol()[source]
Returns:The name of the input column (default: )
Return type:str
getInputCols()[source]
Returns:The name of the input column (default: )
Return type:str
static getJavaPackage()[source]

Returns package name String.

getOutputCol()[source]
Returns:The name of the output column
Return type:str
getUDF()[source]
classmethod read()[source]

Returns an MLReader instance for this class.

setInputCol(value)[source]
Parameters:inputCol (str) – The name of the input column (default: )
setInputCols(value)[source]
Parameters:inputCols (list) – The names of the input columns (default: )
setOutputCol(value)[source]
Parameters:outputCol (str) – The name of the output column
setUDF(udf)[source]