Re: Flink Table API Sum method

2019-01-29 Thread Dawid Wysakowicz
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

Flink Table API Sum method

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