fix(flink): give true division semantics to flink division operation

ibis-project · Oct 29, 2024 · 8df3d9c · 8df3d9c
1 parent 6880375
commit 8df3d9c
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/ibis/backends/sql/compilers/flink.py b/ibis/backends/sql/compilers/flink.py
@@ -328,6 +328,10 @@ def visit_TryCast(self, op, *, arg, to):
             )
         return sge.TryCast(this=arg, to=type_mapper.from_ibis(to))
 
+    def visit_Divide(self, op, *, left, right):
+        dtype = op.dtype
+        return self.cast(left, dtype) / self.cast(right, dtype)
+
     def visit_FloorDivide(self, op, *, left, right):
         return self.f.floor(sge.paren(left) / sge.paren(right))