[FLINK-26203] Support Table API in Pulsar Connector

• Type: New Feature
• Status: In Progress
• Priority: Minor
• Resolution: Unresolved
• Component/s: Connectors / Pulsar
• Labels: Pulsar auto-deprioritized-major pull-request-available
• Assignee: Yufan Sheng
• Reporter: Yufei Zhang
• Created: 17/Feb/22 02:58
• Updated: 02/Jan/24 10:15

Description

Currently Pulsar connector only supports DataStream API. We plan to support Table API as well.

Issue Links

• links to: GitHub Pull Request #56
• links to: GitHub Pull Request #63
• mentioned in: Page Loading...

Sub-Tasks

• Pulsar Table Source code :implementation: Resolved
• Pulsar Table Sink code: implementation: Resolved
• Pulsar Table Connector testing: Resolved
• Pulsar Table Connector pom config and packaging: Open
• Pulsar Table Connector Documentation: Open
• Pulsar SQL Connector: SQLClient E2E testing: Open
• Pulsar Catalog support with Schema translation: Closed