summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--config/udf.plugins2
-rw-r--r--groot-common/src/main/resources/udf.plugins2
-rw-r--r--groot-core/src/main/java/com/geedgenetworks/core/udf/udaf/array/ArrayConcatAgg.java (renamed from groot-core/src/main/java/com/geedgenetworks/core/udf/udaf/array/ArrayContactAgg.java)2
-rw-r--r--groot-core/src/test/java/com/geedgenetworks/core/udf/test/aggregate/ArrayConcatAggTest.java (renamed from groot-core/src/test/java/com/geedgenetworks/core/udf/test/aggregate/ArrayContactAggTest.java)8
4 files changed, 7 insertions, 7 deletions
diff --git a/config/udf.plugins b/config/udf.plugins
index 6a3f245..a7cc218 100644
--- a/config/udf.plugins
+++ b/config/udf.plugins
@@ -37,4 +37,4 @@ com.geedgenetworks.core.udf.udtf.Unroll
com.geedgenetworks.core.udf.udtf.PathUnroll
com.geedgenetworks.core.udf.udaf.Max
com.geedgenetworks.core.udf.udaf.Min
-com.geedgenetworks.core.udf.udaf.array.ArrayContactAgg \ No newline at end of file
+com.geedgenetworks.core.udf.udaf.array.ArrayConcatAgg \ No newline at end of file
diff --git a/groot-common/src/main/resources/udf.plugins b/groot-common/src/main/resources/udf.plugins
index 6a3f245..a7cc218 100644
--- a/groot-common/src/main/resources/udf.plugins
+++ b/groot-common/src/main/resources/udf.plugins
@@ -37,4 +37,4 @@ com.geedgenetworks.core.udf.udtf.Unroll
com.geedgenetworks.core.udf.udtf.PathUnroll
com.geedgenetworks.core.udf.udaf.Max
com.geedgenetworks.core.udf.udaf.Min
-com.geedgenetworks.core.udf.udaf.array.ArrayContactAgg \ No newline at end of file
+com.geedgenetworks.core.udf.udaf.array.ArrayConcatAgg \ No newline at end of file
diff --git a/groot-core/src/main/java/com/geedgenetworks/core/udf/udaf/array/ArrayContactAgg.java b/groot-core/src/main/java/com/geedgenetworks/core/udf/udaf/array/ArrayConcatAgg.java
index 04e8cce..76fbfc9 100644
--- a/groot-core/src/main/java/com/geedgenetworks/core/udf/udaf/array/ArrayContactAgg.java
+++ b/groot-core/src/main/java/com/geedgenetworks/core/udf/udaf/array/ArrayConcatAgg.java
@@ -13,7 +13,7 @@ import java.util.*;
/**
* Aggregates elements within a group and returns a collection based on mode (list or set).
*/
-public class ArrayContactAgg implements AggregateFunction {
+public class ArrayConcatAgg implements AggregateFunction {
private String lookupField;
private String outputField;
diff --git a/groot-core/src/test/java/com/geedgenetworks/core/udf/test/aggregate/ArrayContactAggTest.java b/groot-core/src/test/java/com/geedgenetworks/core/udf/test/aggregate/ArrayConcatAggTest.java
index 8eec775..742a160 100644
--- a/groot-core/src/test/java/com/geedgenetworks/core/udf/test/aggregate/ArrayContactAggTest.java
+++ b/groot-core/src/test/java/com/geedgenetworks/core/udf/test/aggregate/ArrayConcatAggTest.java
@@ -3,7 +3,7 @@ import com.geedgenetworks.api.common.udf.UDFContext;
import com.geedgenetworks.api.event.Event;
import com.geedgenetworks.common.config.Accumulator;
import com.geedgenetworks.common.exception.GrootStreamRuntimeException;
-import com.geedgenetworks.core.udf.udaf.array.ArrayContactAgg;
+import com.geedgenetworks.core.udf.udaf.array.ArrayConcatAgg;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
@@ -12,15 +12,15 @@ import java.util.*;
import static org.junit.jupiter.api.Assertions.*;
-class ArrayContactAggTest {
+class ArrayConcatAggTest {
- private ArrayContactAgg aggFunction;
+ private ArrayConcatAgg aggFunction;
private UDFContext udfContext;
private Accumulator accumulator;
@BeforeEach
void setUp() {
- aggFunction = new ArrayContactAgg();
+ aggFunction = new ArrayConcatAgg();
udfContext = new UDFContext();
udfContext.setLookupFields(Collections.singletonList("field1"));
udfContext.setParameters(new HashMap<>());