Skip to content

Commit fe4a7ab

Browse files
committed
Add list_cat, list_concat
1 parent cbe28cb commit fe4a7ab

File tree

2 files changed

+26
-0
lines changed

2 files changed

+26
-0
lines changed

python/datafusion/functions.py

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -147,6 +147,8 @@
147147
"length",
148148
"levenshtein",
149149
"list_append",
150+
"list_cat",
151+
"list_concat",
150152
"list_dims",
151153
"list_distinct",
152154
"list_element",
@@ -1142,6 +1144,22 @@ def array_distinct(array: Expr) -> Expr:
11421144
return Expr(f.array_distinct(array.expr))
11431145

11441146

1147+
def list_cat(*args: Expr) -> Expr:
1148+
"""Concatenates the input arrays.
1149+
1150+
This is an alias for :py:func:`array_concat`, :py:func:`array_cat`.
1151+
"""
1152+
return array_concat(*args)
1153+
1154+
1155+
def list_concat(*args: Expr) -> Expr:
1156+
"""Concatenates the input arrays.
1157+
1158+
This is an alias for :py:func:`array_concat`, :py:func:`array_cat`.
1159+
"""
1160+
return array_concat(*args)
1161+
1162+
11451163
def list_distinct(array: Expr) -> Expr:
11461164
"""Returns distinct values from the array after removing duplicates.
11471165

python/tests/test_functions.py

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -289,6 +289,14 @@ def py_flatten(arr):
289289
lambda col: f.array_cat(col, col),
290290
lambda data: [np.concatenate([arr, arr]) for arr in data],
291291
],
292+
[
293+
lambda col: f.list_cat(col, col),
294+
lambda data: [np.concatenate([arr, arr]) for arr in data],
295+
],
296+
[
297+
lambda col: f.list_concat(col, col),
298+
lambda data: [np.concatenate([arr, arr]) for arr in data],
299+
],
292300
[
293301
lambda col: f.array_dims(col),
294302
lambda data: [[len(r)] for r in data],

0 commit comments

Comments
 (0)