Class MLPredictTableFunction
- java.lang.Object
-
- org.apache.flink.table.functions.UserDefinedFunction
-
- org.apache.flink.table.functions.TableFunction<org.apache.flink.types.Row>
-
- com.codedstreams.otterstreams.sql.udf.MLPredictTableFunction
-
- All Implemented Interfaces:
Serializable,org.apache.flink.table.functions.FunctionDefinition
public class MLPredictTableFunction extends org.apache.flink.table.functions.TableFunction<org.apache.flink.types.Row>Table function that returns multiple rows. Usage: SELECT * FROM table, LATERAL TABLE(ML_PREDICT_TABLE('model', features))- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description MLPredictTableFunction()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voideval(String modelName, String featuresJson)-
Methods inherited from class org.apache.flink.table.functions.TableFunction
collect, finish, getKind, getParameterTypes, getResultType, getTypeInference, setCollector
-
Methods inherited from class org.apache.flink.table.functions.UserDefinedFunction
close, functionIdentifier, open, toString
-
-