diff --git a/ibis/backends/flink/registry.py b/ibis/backends/flink/registry.py index dffb3f2beb03..8e6bf3cf605b 100644 --- a/ibis/backends/flink/registry.py +++ b/ibis/backends/flink/registry.py @@ -4,7 +4,11 @@ import ibis.common.exceptions as com import ibis.expr.operations as ops -from ibis.backends.base.sql.registry import helpers, window +from ibis.backends.base.sql.registry import ( + fixed_arity, + helpers, + window, +) from ibis.backends.base.sql.registry import ( operation_registry as base_operation_registry, ) @@ -188,6 +192,7 @@ def _window(translator: ExprTranslator, op: ops.Node) -> str: ops.ExtractMinute: _extract_field("minute"), # equivalent to MINUTE(timestamp) ops.ExtractSecond: _extract_field("second"), # equivalent to SECOND(timestamp) ops.Literal: _literal, + ops.RegexSearch: fixed_arity("regexp", 2), ops.TimestampFromUNIX: _timestamp_from_unix, ops.Where: _filter, ops.Window: _window,