Skip to content

Commit

Permalink
fix(flink): correct ops.RegexSearch translations
Browse files Browse the repository at this point in the history
  • Loading branch information
deepyaman authored and jcrist committed Aug 31, 2023
1 parent 52f7032 commit a3427a1
Showing 1 changed file with 6 additions and 1 deletion.
7 changes: 6 additions & 1 deletion ibis/backends/flink/registry.py
Original file line number Diff line number Diff line change
Expand Up @@ -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,
)
Expand Down Expand Up @@ -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,
Expand Down

0 comments on commit a3427a1

Please sign in to comment.