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"))
signature.asc
Description: OpenPGP digital signature
