diff options
| -rw-r--r-- | config/udf.plugins | 2 | ||||
| -rw-r--r-- | groot-common/src/main/resources/udf.plugins | 2 | ||||
| -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<>()); |
