[FLINK-36132] Remove codes that references TableSource and TableSink directly at the API level.

• Type: Technical Debt
• Status: In Progress
• Priority: Blocker
• Resolution: Unresolved
• Fix Version/s: 2.0.0
• Component/s: Table SQL / API, Table SQL / Planner
• Labels: 2.0-related
• Assignee: xuyang
• Reporter: xuyang
• Created: 22/Aug/24 10:11
• Updated: 09/Oct/24 02:18

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)

...

Issue Links

• Blocked: FLINK-33748 Remove legacy TableSource/TableSink API in 2.0
• blocks: FLINK-36133 Remove subclass implementations of TableSource and TableSink, along with their corresponding Factory classes.
• is blocked by: FLINK-36284 StreamTableEnvironment#toDataStream(Table table, Class<T> targetClass) is not suitable for setting targetClass as a class generated by Avro.

Sub-Tasks

• Remove TestTableSourceWithTime and its subclasses to prepare to remove TableEnvironmentInternal#registerTableSourceInternal: Closed
• Remove `register_table_source` and `register_table_sink` in python module: Closed
• Remove `fromTableSource` in python module: Open
• Remove all direct uses of `TableEnvironmentInternal#registerTableSourceInternal` in table module: Open