You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Soheil Pourbafrani <so...@gmail.com> on 2019/01/29 14:13:31 UTC

Flink Table API Sum method

Hi,

How can I use the Flink Table API SUM function? For example something like
this:
table.agg(sum("feild1"))

Re: Flink Table API Sum method

Posted by Dawid Wysakowicz <dw...@apache.org>.

Hi,

It depends if you are using scala or java.

In scala: table.agg('field1.sum)

In java (this should work in scala as well): table("field1.sum")

More examples you can find in the docs[1]

[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/table/tableApi.html#aggregations

On 29/01/2019 15:13, Soheil Pourbafrani wrote:
> Hi,
>
> How can I use the Flink Table API SUM function? For example something
> like this:
> table.agg(sum("feild1"))