summaryrefslogtreecommitdiff
path: root/groot-common/src/main
diff options
context:
space:
mode:
authorwangkuan <[email protected]>2024-08-29 18:47:29 +0800
committerwangkuan <[email protected]>2024-08-29 18:47:29 +0800
commit13323b1fe6315cedc5e312fe084fb883442fe066 (patch)
tree3dd004159328b48c3e3b2a24ef7f632798ccd690 /groot-common/src/main
parent0ea9b9d9db5f92e7afd7b86ddad1f8d69d5c0945 (diff)
[improve][bootstrap]增加未提交的文件,删除获取中间值方法
Diffstat (limited to 'groot-common/src/main')
-rw-r--r--groot-common/src/main/java/com/geedgenetworks/common/udf/AggregateFunction.java1
1 files changed, 0 insertions, 1 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 6e5ab80..6f6e048 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
@@ -11,7 +11,6 @@ public interface AggregateFunction extends Serializable {
Accumulator initAccumulator(Accumulator acc);
Accumulator add(Event val, Accumulator acc);
String functionName();
- default Accumulator getMiddleResult(Accumulator acc){return acc;}
Accumulator getResult(Accumulator acc);
Accumulator merge(Accumulator a, Accumulator b);
default void close(){};