Currently, this functionality is hard-coded in the aggregation
translation. Namely in
`org.apache.flink.table.runtime.aggregate.AggregateUtil#transformToAggregateFunctions`
[1].
Timo
[1]
https://github.com/apache/flink/blob/master/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
Am 08.01.19 um 06:41 schrieb yinhua.dai:
Hi Timo,
Can you let me know how the build-in "MAX" function able to support
different types?
Thanks.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
