org.apache.flink.table.types.extraction

Class TypeInferenceExtractor

java.lang.Object

org.apache.flink.table.types.extraction.TypeInferenceExtractor

@Internal
public final class TypeInferenceExtractor
extends Object

Reflection-based utility for extracting a TypeInference from a supported subclass of UserDefinedFunction.

The behavior of this utility can be influenced by DataTypeHints and FunctionHints which have higher precedence than the reflective information.

Note: This utility assumes that functions have been validated before regarding accessibility of class/methods and serializability.

Constructor Summary

Constructors

Constructor and Description
TypeInferenceExtractor()

Method Summary

Modifier and Type	Method and Description
static TypeInference	forAggregateFunction(DataTypeFactory typeFactory, Class<? extends AggregateFunction<?,?>> function) Extracts a type inference from a AggregateFunction.
static TypeInference	forAsyncTableFunction(DataTypeFactory typeFactory, Class<? extends AsyncTableFunction<?>> function) Extracts a type inference from a AsyncTableFunction.
static TypeInference	forScalarFunction(DataTypeFactory typeFactory, Class<? extends ScalarFunction> function) Extracts a type inference from a ScalarFunction.
static TypeInference	forTableAggregateFunction(DataTypeFactory typeFactory, Class<? extends TableAggregateFunction<?,?>> function) Extracts a type inference from a TableAggregateFunction.
static TypeInference	forTableFunction(DataTypeFactory typeFactory, Class<? extends TableFunction<?>> function) Extracts a type inference from a TableFunction.

Methods inherited from class java.lang.Object

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

Constructor Detail

TypeInferenceExtractor

public TypeInferenceExtractor()

Method Detail

forScalarFunction

public static TypeInference forScalarFunction(DataTypeFactory typeFactory,
                                              Class<? extends ScalarFunction> function)

Extracts a type inference from a ScalarFunction.

forAggregateFunction

public static TypeInference forAggregateFunction(DataTypeFactory typeFactory,
                                                 Class<? extends AggregateFunction<?,?>> function)

Extracts a type inference from a AggregateFunction.

forTableFunction

public static TypeInference forTableFunction(DataTypeFactory typeFactory,
                                             Class<? extends TableFunction<?>> function)

Extracts a type inference from a TableFunction.

forTableAggregateFunction

public static TypeInference forTableAggregateFunction(DataTypeFactory typeFactory,
                                                      Class<? extends TableAggregateFunction<?,?>> function)

Extracts a type inference from a TableAggregateFunction.

forAsyncTableFunction

public static TypeInference forAsyncTableFunction(DataTypeFactory typeFactory,
                                                  Class<? extends AsyncTableFunction<?>> function)

Extracts a type inference from a AsyncTableFunction.