fix(flink): translate ops.RandomScalar to rand

ibis-project · Sep 14, 2023 · c485a92 · c485a92
1 parent 8f2a40f
commit c485a92
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/ibis/backends/flink/registry.py b/ibis/backends/flink/registry.py
@@ -195,6 +195,7 @@ def _floor_divide(translator: ExprTranslator, op: ops.Node) -> str:
     {
         # Unary operations
         ops.NullIfZero: _nullifzero,
+        ops.RandomScalar: lambda *_: "rand()",
         ops.Degrees: unary("degrees"),
         ops.Radians: unary("radians"),
         # Unary aggregates