Class 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
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void eval​(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
      • Methods inherited from interface org.apache.flink.table.functions.FunctionDefinition

        getRequirements, isDeterministic
    • Constructor Detail

      • MLPredictTableFunction

        public MLPredictTableFunction()
    • Method Detail

      • eval

        public void eval​(String modelName,
                         String featuresJson)