Added support for arrayFlatten

crobox · Aug 29, 2023 · 69f68d0 · 69f68d0
1 parent b49b9f6
commit 69f68d0
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/dsl/src/it/scala/com/crobox/clickhouse/dsl/column/ArrayFunctionsIT.scala b/dsl/src/it/scala/com/crobox/clickhouse/dsl/column/ArrayFunctionsIT.scala
@@ -92,5 +92,9 @@ class ArrayFunctionsIT extends DslITSpec {
     execute(select(ArrayFlatten(Array(Array(Array("1")), Array(Array("2"), Array("3", "4")))))).futureValue should be(
       "['1','2','3','4']"
     )
+
+    execute(select(arrayFlatten(Array(Array(Array("1")), Array(Array("2"), Array("3", "4")))))).futureValue should be(
+      "['1','2','3','4']"
+    )
   }
 }
diff --git a/dsl/src/main/scala/com.crobox.clickhouse/dsl/column/ArrayFunctions.scala b/dsl/src/main/scala/com.crobox.clickhouse/dsl/column/ArrayFunctions.scala
@@ -161,5 +161,6 @@ trait ArrayFunctions { this: Magnets =>
   def arrayLength(col: ArrayColMagnet[_]): ArrayLength = ArrayLength(col)
   def length(col: ArrayColMagnet[_]): ArrayLength      = ArrayLength(col)
 
-  def flatten[_](col: ArrayColMagnet[_]): ArrayFlatten[_] = ArrayFlatten(col)
+  def arrayFlatten[V](col: ArrayColMagnet[V]): ArrayFlatten[V] = ArrayFlatten(col)
+  def flatten[V](col: ArrayColMagnet[V]): ArrayFlatten[V]      = ArrayFlatten(col)
 }