New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[FLINK-15567][table][docs] Add documentation for INSERT statements for Flink SQL #10839
Conversation
cc @JingsongLi |
Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community Automated ChecksLast check on commit c5595ea (Mon Jan 13 08:33:21 UTC 2020) ✅no warnings Mention the bot in a comment to re-run the automated checks. Review Progress
Please see the Pull Request Review Guide for a full explanation of the review process. The Bot is tracking the review progress through labels. Labels are applied according to the order of the review items. For consensus, approval by a Flink committer of PMC member is required Bot commandsThe @flinkbot bot supports the following commands:
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks @wuchong
|
||
## Run an INSERT statement | ||
|
||
INSERT statements are specified with the `sqlUpdate()` method of the `TableEnvironment` or executed in [SQL CLI]({{ site.baseurl }}/dev/table/sqlClient.html). The method `sqlUpdate()` for INSERT statements is a lazy execution, they will be executed only when `TableEnvironment.execute(jobName)` is invoked. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Maybe we can point to https://ci.apache.org/projects/flink/flink-docs-master/dev/table/sqlClient.html#detached-sql-queries
to emphasize detach
.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Why should we emphasize detach
mode here? It is not related to the sqlUpdate()
problem.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
ok
docs/dev/table/sql/insert.md
Outdated
SELECT user, cnt FROM page_view_source; | ||
|
||
-- Overwrites the partition (date='2019-8-30', country='China') using rows in page_view_source | ||
INSERT INTO country_page_view PARTITION (date='2019-8-30', country='China') |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Can you add append/overwrite dynamic partition inserting?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Sure.
docs/dev/table/sql/insert.md
Outdated
INSERT INTO country_page_view PARTITION (date='2019-8-30', country='China') | ||
SELECT user, cnt FROM page_view_source; | ||
|
||
-- Overwrites the partition (date='2019-8-30', country='China') using rows in page_view_source | ||
-- Appends rows into partition (date, country), where date is static partition with value '2019-8-30', | ||
-- country is dynamic partition whose value is dynamic determined by each row. | ||
INSERT INTO country_page_view PARTITION (date='2019-8-30', country='China') |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Remove , country='China'
LGTM |
Thanks @JingsongLi , Merging... |
What is the purpose of the change
We missed to add documentation for INSERT statements which should be added under "SQL" page.
Brief change log
Add
insert.md
andinsert.zh.md
undersql
directory.Verifying this change
No tests required.
Does this pull request potentially affect one of the following parts:
@Public(Evolving)
: (yes / no)Documentation