diff --git a/ibis/backends/snowflake/registry.py b/ibis/backends/snowflake/registry.py index 2373dd7d9534..4ce03b0d8bc4 100644 --- a/ibis/backends/snowflake/registry.py +++ b/ibis/backends/snowflake/registry.py @@ -422,6 +422,7 @@ def _timestamp_bucket(t, op): ops.ArrayZip: _array_zip, ops.ArraySort: unary(sa.func.array_sort), ops.ArrayRepeat: fixed_arity(sa.func.ibis_udfs.public.array_repeat, 2), + ops.ArrayFlatten: fixed_arity(sa.func.array_flatten, 1), ops.StringSplit: fixed_arity(sa.func.split, 2), # snowflake typeof only accepts VARIANT, so we cast ops.TypeOf: unary(lambda arg: sa.func.typeof(sa.func.to_variant(arg))),