fix(flink): correct the translation of ops.Power

ibis-project · Sep 13, 2023 · 42d2236 · 42d2236
1 parent 95474e6
commit 42d2236
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/ibis/backends/flink/registry.py b/ibis/backends/flink/registry.py
@@ -219,6 +219,7 @@ def _floor_divide(translator: ExprTranslator, op: ops.Node) -> str:
         ops.TimestampFromUNIX: _timestamp_from_unix,
         ops.Window: _window,
         # Binary operations
+        ops.Power: fixed_arity("power", 2),
         ops.FloorDivide: _floor_divide,
     }
 )