-
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.
- causes
-
FLINK-20747 ClassCastException when using MAX aggregate function
-
- Closed
-
- relates to
-
-
- Resolved
-
1.
|
Support the new type inference in Scala Table API functions |
|
Open | Unassigned | |
2.
|
Update test utilities to FLIP-65 |
|
Open | Unassigned | |
3.
|
Use the new type inference for hive udtf |
|
Open | Unassigned | |
4.
|
Use the new type inference for hive udaf |
|
Open | Unassigned | |
5.
|
Support new type inference for Table#flatMap |
|
Open | Unassigned | |
6.
|
Drop old user-defined function stack |
|
Open | Timo Walther |
