what's the datasets used in flink sql document?

[大森林]

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

[Piotr Nowojski-4]

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 大森林 <[hidden email]> 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

[大森林]

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" <[hidden email]>;

发送时间: 2020年10月14日(星期三) 晚上9:52

收件人: "大森林"<[hidden email]>;

抄送: "user"<[hidden email]>;

主题: 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 大森林 <[hidden email]> 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

[Piotr Nowojski-4]

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 大森林 <[hidden email]> 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" <[hidden email]>;

发送时间: 2020年10月14日(星期三) 晚上9:52

收件人: "大森林"<[hidden email]>;

抄送: "user"<[hidden email]>;

主题: 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 大森林 <[hidden email]> 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

[大森林]

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" <[hidden email]>;

发送时间: 2020年10月14日(星期三) 晚上10:20

收件人: "大森林"<[hidden email]>;

抄送: "user"<[hidden email]>;

主题: 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 大森林 <[hidden email]> 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" <[hidden email]>;

发送时间: 2020年10月14日(星期三) 晚上9:52

收件人: "大森林"<[hidden email]>;

抄送: "user"<[hidden email]>;

主题: 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 大森林 <[hidden email]> 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

[Piotr Nowojski-4]

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 大森林 <[hidden email]> 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" <[hidden email]>;

发送时间: 2020年10月14日(星期三) 晚上10:20

收件人: "大森林"<[hidden email]>;

抄送: "user"<[hidden email]>;

主题: 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 大森林 <[hidden email]> 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" <[hidden email]>;

发送时间: 2020年10月14日(星期三) 晚上9:52

收件人: "大森林"<[hidden email]>;

抄送: "user"<[hidden email]>;

主题: 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 大森林 <[hidden email]> 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

[David Anderson-3]

For a dockerized playground that includes a dataset, many working examples, and training slides, see [1].

[1] https://github.com/ververica/sql-training

David

On Thu, Oct 15, 2020 at 10:18 AM Piotr Nowojski <[hidden email]> wrote:

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 大森林 <[hidden email]> 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" <[hidden email]>;

发送时间: 2020年10月14日(星期三) 晚上10:20

收件人: "大森林"<[hidden email]>;

抄送: "user"<[hidden email]>;

主题: 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 大森林 <[hidden email]> 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" <[hidden email]>;

发送时间: 2020年10月14日(星期三) 晚上9:52

收件人: "大森林"<[hidden email]>;

抄送: "user"<[hidden email]>;

主题: 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 大森林 <[hidden email]> 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