Merge branch 'feature/aggregate' into 'develop'

[improve][core]拆分聚合函数open方法,较少调用次数,优化性能

See merge request galaxy/platform/groot-stream!91

1 files changed, 4 insertions, 3 deletions

diff --git a/groot-common/src/main/java/com/geedgenetworks/common/udf/AggregateFunction.java b/groot-common/src/main/java/com/geedgenetworks/common/udf/AggregateFunction.java
index 98450fd..455073f 100644
--- a/groot-common/src/main/java/com/geedgenetworks/common/udf/AggregateFunction.java
+++ b/groot-common/src/main/java/com/geedgenetworks/common/udf/AggregateFunction.java
@@ -7,7 +7,9 @@ import java.io.Serializable;
 
 public interface AggregateFunction extends Serializable {
 
-    Accumulator open(UDFContext udfContext,Accumulator acc);
+    void open(UDFContext udfContext);
+
+    Accumulator initAccumulator(Accumulator acc);
 
     Accumulator add(Event val, Accumulator acc);
 
@@ -15,6 +17,5 @@ public interface AggregateFunction extends Serializable {
 
     Accumulator getResult(Accumulator acc);
 
-    void close();
-
+    default void close(){};
 }