Package com.codedstreams.otterstreams.sql.udf

Class MLPredictScalarFunction

java.lang.Object

org.apache.flink.table.functions.UserDefinedFunction

org.apache.flink.table.functions.ScalarFunction

com.codedstreams.otterstreams.sql.udf.MLPredictScalarFunction

All Implemented Interfaces:

Serializable, org.apache.flink.table.functions.FunctionDefinition

public class MLPredictScalarFunction
extends org.apache.flink.table.functions.ScalarFunction

Flink SQL Scalar Function for ML model inference. Usage: SELECT ML_PREDICT('model-name', '{"feature1": 1.0}') FROM table

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
MLPredictScalarFunction()

Method Summary

Modifier and Type	Method	Description
void	close()
Double	eval(String modelName, String featuresJson)

Methods inherited from class org.apache.flink.table.functions.ScalarFunction

getKind, getParameterTypes, getResultType, getTypeInference

Methods inherited from class org.apache.flink.table.functions.UserDefinedFunction

functionIdentifier, open, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.functions.FunctionDefinition

getRequirements, isDeterministic

Constructor Detail

MLPredictScalarFunction

public MLPredictScalarFunction()

Method Detail

eval

public Double eval(String modelName,
                   String featuresJson)

close

public void close()

Overrides:

close in class org.apache.flink.table.functions.UserDefinedFunction