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

ibis-project · Oct 24, 2024 · 1dfbea0 · 1dfbea0
1 parent d458138
commit 1dfbea0
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
@@ -329,6 +329,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(left / right)