Hi All, Could you please tell how to register custom Aggregation function in blink batch app? In case of streaming mode: We create
EnvironmentSettings bsSettings = EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build(); StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env, bsSettings); Which has: <T, ACC> void registerFunction(String name, AggregateFunction<T, ACC> aggregateFunction); But in case of batchMode, we need to create TableEnvironment: EnvironmentSettings bsSettings = EnvironmentSettings.newInstance().useBlinkPlanner().inBatchMode().build(); tEnv = TableEnvironment.create(bsSettings); Which does not have this function to register AggregationFunction, only Scalar one. Details: Flink 1.10, Java API