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
>>
>>

Reply via email to