Class SystemTypeInference
- java.lang.Object
-
- org.apache.flink.table.types.inference.SystemTypeInference
-
@Internal public class SystemTypeInference extends Object
Extends theTypeInferencefunction-aware by additional system columns and validation.During planning system columns are available and can be accessed in SQL, during runtime those columns are not passed or returned by the eval() method. They are handled with custom code paths.
For example, for
ProcessTableFunction, this utility class implicitly adds the optionaluidandon_timeargs and an additionalrowtimecolumn in the output. Additionally, it adds a validation layer for complexStaticArguments.
-
-
Constructor Summary
Constructors Constructor Description SystemTypeInference()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static TypeInferenceof(FunctionKind functionKind, TypeInference origin)
-
-
-
Method Detail
-
of
public static TypeInference of(FunctionKind functionKind, TypeInference origin)
-
-