[core] Refactor the Field Aggregator factory to validate data types when creating function

apache / paimon

Apache Paimon is a lake format that enables building a Realtime Lakehouse Architecture with Flink and Spark for both streaming and batch operations.

https://paimon.apache.org/

Apache License 2.0

2.43k stars 956 forks source link

Closed zhuangchong closed 2 weeks ago

zhuangchong commented 2 weeks ago

1.Validate data types when creating aggregate functions, not at calculating 2.Create aggregate function in factory class

org.apache.paimon.mergetree.compact.aggregate.FieldAggregatorTest