Package com.codedstreams.otterstreams.sql.udf

Class MLInferenceFunctionFactory

java.lang.Object

com.codedstreams.otterstreams.sql.udf.MLInferenceFunctionFactory

All Implemented Interfaces:

org.apache.flink.table.factories.FunctionDefinitionFactory

public class MLInferenceFunctionFactory
extends Object
implements org.apache.flink.table.factories.FunctionDefinitionFactory

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.factories.FunctionDefinitionFactory

org.apache.flink.table.factories.FunctionDefinitionFactory.Context

Constructor Summary

Constructors

Constructor	Description
MLInferenceFunctionFactory()

Method Summary

Modifier and Type	Method	Description
org.apache.flink.table.functions.FunctionDefinition	createFunctionDefinition(String name, org.apache.flink.table.catalog.CatalogFunction catalogFunction, org.apache.flink.table.factories.FunctionDefinitionFactory.Context context)
String	factoryIdentifier()
Set	requirements()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.factories.FunctionDefinitionFactory

createFunctionDefinition

Constructor Detail

MLInferenceFunctionFactory

public MLInferenceFunctionFactory()

Method Detail

factoryIdentifier

public String factoryIdentifier()

requirements

public Set requirements()

createFunctionDefinition

public org.apache.flink.table.functions.FunctionDefinition createFunctionDefinition(String name,
                                                                                    org.apache.flink.table.catalog.CatalogFunction catalogFunction,
                                                                                    org.apache.flink.table.factories.FunctionDefinitionFactory.Context context)

Specified by:

createFunctionDefinition in interface org.apache.flink.table.factories.FunctionDefinitionFactory