Hi, The examples in the documentation are not fully functional. They assume (like in this case), that you would have an already predefined table orders, with the required fields. As I mentioned before, there are working examples available and you can also read the documentation on how to register tables on your own (both linked in my previous messages).
Best Piotrek śr., 14 paź 2020 o 18:12 大森林 <appleyu...@foxmail.com> napisał(a): > 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>; > *发送时间:* 2020年10月14日(星期三) 晚上10:20 > *收件人:* "大森林"<appleyu...@foxmail.com>; > *抄送:* "user"<user@flink.apache.org>; > *主题:* 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] > https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/common.html#query-a-table > [2] > 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 大森林 <appleyu...@foxmail.com> napisał(a): > >> 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>; >> *发送时间:* 2020年10月14日(星期三) 晚上9:52 >> *收件人:* "大森林"<appleyu...@foxmail.com>; >> *抄送:* "user"<user@flink.apache.org>; >> *主题:* Re: what's the datasets used in flink sql document? >> >> Hi, >> >> It depends how you defined `orders` in your example. For example here [1] >> >> > 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] >> https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/tableApi.html#overview--examples >> [2] >> 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 大森林 <appleyu...@foxmail.com> napisał(a): >> >>> Could anyone tell me >>> 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 >>> >>>
