回复： what's the datasets used in flink sql document?

[大森林]

much Manks for your replies


I mean,where the "france revenue"
in the following document ?
https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/common.html


Thanks for your help～


------------------ 原始邮件 ------------------
发件人:                                                                            
                                            "Piotr Nowojski"                    
                                                                
<pnowoj...@apache.org&gt;;
发送时间:&nbsp;2020年10月14日(星期三) 晚上10:20
收件人:&nbsp;"大森林"<appleyu...@foxmail.com&gt;;
抄送:&nbsp;"user"<user@flink.apache.org&gt;;
主题:&nbsp;Re: what's the datasets used in flink sql document?



Hi,

Can you link what document do you have in mind? The documentation [1]? I don't 
think so.


There are working examples,  located in the binary distribution under the 
`examples/table/` directory. Their code is available in the repository [2].


Best regards,
Piotrek


[1]&nbsp;https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/common.html#query-a-table
[2]&nbsp;https://github.com/apache/flink/tree/master/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/basics


śr., 14 paź 2020 o 15:55&nbsp;大森林 <appleyu...@foxmail.com&gt; napisał(a):

sorry that I did not make it clear.


I mean:
Is there such a dataset can be downloaded&nbsp;
to satisfy all the examples in the document?


Thanks for your help


------------------&nbsp;原始邮件&nbsp;------------------
发件人:                                                                            
                                            "Piotr Nowojski"                    
                                                                
<pnowoj...@apache.org&gt;;
发送时间:&nbsp;2020年10月14日(星期三) 晚上9:52
收件人:&nbsp;"大森林"<appleyu...@foxmail.com&gt;;
抄送:&nbsp;"user"<user@flink.apache.org&gt;;
主题:&nbsp;Re: what's the datasets used in flink sql document?



Hi,

It depends how you defined `orders` in your example. For example here [1]


&gt;&nbsp;Table orders = tEnv.from("Orders"); // schema (a, b, c, rowtime)


`orders` is obtained from the environment, from a table registered under the 
name "Orders". You would need to first register such table, or register a 
catalog with such table [2]


Piotrek


[1]&nbsp;https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/tableApi.html#overview--examples
[2]&nbsp;https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/common.html#create-a-tableenvironment


śr., 14 paź 2020 o 15:15&nbsp;大森林 <appleyu...@foxmail.com&gt; napisał(a):

Could anyone tell me&nbsp;
what's the datasets used in flink sql document?


For sql like:
val revenue = orders   .filter($"cCountry" === "FRANCE")   .groupBy($"cID", 
$"cName")   .select($"cID", $"cName", $"revenue".sum AS "revSum")
Thanks for your help