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

[大森林]

sorry that I did not make it clear.


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


Thanks for your help


------------------ 原始邮件 ------------------
发件人:                                                                            
                                            "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