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

XML

Word

Printable

JSON

Details

Type: Improvement
Status: Closed
Priority: Major
Resolution: Resolved
Affects Version/s: None
Fix Version/s: 1.9.4, 1.10.1, 1.11.0
Component/s: API / Python, Documentation
Labels:
- beginners
- pull-request-available

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.

Attachments

Issue Links

links to

GitHub Pull Request #11945

Activity

People

Assignee:: Shuiqiang Chen

Reporter:: sunjincheng

Votes:: 0 Vote for this issue

Watchers:: 4 Start watching this issue

Dates

Created:: 20/Apr/20 06:07

Updated:: 30/Apr/20 01:45

Resolved:: 30/Apr/20 01:45