Skip to content

Commit 640234b

Browse files
cpcloudkszucs
authored andcommitted
feat(pyspark): implement nullifzero
1 parent addb2c1 commit 640234b

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

ibis/backends/pyspark/compiler.py

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1923,3 +1923,10 @@ def compile_unnest(t, expr, scope, timecontext, **kwargs):
19231923
op = expr.op()
19241924
column = t.translate(op.arg, scope, timecontext, **kwargs)
19251925
return F.explode(column)
1926+
1927+
1928+
@compiles(ops.NullIfZero)
1929+
def compile_null_if_zero(t, expr, scope, timecontext, **kwargs):
1930+
op = expr.op()
1931+
arg = t.translate(op.arg, scope, timecontext, **kwargs)
1932+
return F.when(arg == 0, F.lit(None)).otherwise(arg)

0 commit comments

Comments
 (0)