-
Type:
New Feature
-
Status: Open
-
Priority:
Major
-
Resolution: Unresolved
-
Affects Version/s: None
-
Fix Version/s: None
-
Component/s: Table SQL / API
-
Labels:None
Currently, the input, accumulator, and output types of UDFs are partially defined within an UDF and outside of the UDF in language-specific table environments (Scala vs. Java). This makes UDFs environment-dependent and not modular. It also blocks the unified org.apache.flink.table.api.TableEnvironment.
A better approach is to perform the type extraction Table API specific within the UDF and let users add additional information through UDF annotations.
An exact annotation and extraction design will follow.
- relates to
-
FLINK-16268 Failed to run rank over window with Hive built-in functions
-
- Resolved
-