[FLINK-17254] Improve the PyFlink documentation and examples to use SQL DDL for source/sink definition

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Resolved
• Fix Version/s: 1.9.4, 1.10.1, 1.11.0
• Component/s: API / Python, Documentation
• Labels: beginners pull-request-available
• Assignee: Shuiqiang Chen
• Reporter: sunjincheng
• Created: 20/Apr/20 06:07
• Updated: 30/Apr/20 01:45
• Resolved: 30/Apr/20 01:45

Description

Currently there are two ways to register a table sink/source in PyFlink table API:
1) TableEnvironment.connect
2) TableEnvironment.sql_update
I think it's better to provide documentation and examples on how to use 2) in PyFlink.

Issue Links

• links to: GitHub Pull Request #11945