Details
-
Technical Debt
-
Status: In Progress
-
Blocker
-
Resolution: Unresolved
-
None
Description
This Jira is a sub-task in https://issues.apache.org/jira/browse/FLINK-33748
This Jira is responsible for the following removal:
● Remove APIs related to TableEnvironmentInternal
○ #fromTableSource
○ #registerTableSourceInternal
○ #registerTableSinkInternal
● Remove APIs related to StreamTableEnvironment
○ #toAppendStream
○ #toRetractStream
● Update subclasses of Operation
○ Remove TableSourceQueryOperation
○ Update QueryOperationCatalogViewTable
○ Remove UnregisteredSinkModifyOperation
○ Remove RichTableSourceQueryOperation (heavily tested, consider a separate PR)
○ Remove OutputConversionModifyOperation (this part is pending, depends on Python)
...
Attachments
Issue Links
- Blocked
-
-
- Open
-
- blocks
-
FLINK-36133 Remove subclass implementations of TableSource and TableSink, along with their corresponding Factory classes.
-
- Open
-
- is blocked by
-
FLINK-36284 StreamTableEnvironment#toDataStream(Table table, Class<T> targetClass) is not suitable for setting targetClass as a class generated by Avro.
-
- Closed
-
1.
|
Remove `fromTableSource` in python module |
|
Open | Unassigned |
2.
|
Remove all direct uses of `TableEnvironmentInternal#registerTableSourceInternal` in table module |
|
Open | Unassigned |