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