|
28 | 28 | import pandas as pd |
29 | 29 |
|
30 | 30 | from bigframes.core.compile.constants import UNIT_TO_US_CONVERSION_FACTORS |
31 | | -import bigframes.core.compile.default_ordering |
| 31 | +import bigframes.core.compile.ibis_compiler.default_ordering |
32 | 32 | from bigframes.core.compile.ibis_compiler.scalar_op_compiler import ( |
33 | 33 | scalar_op_compiler, # TODO(tswast): avoid import of variables |
34 | 34 | ) |
@@ -1064,7 +1064,7 @@ def isin_op_impl(x: ibis_types.Value, op: ops.IsInOp): |
1064 | 1064 | if op.match_nulls and contains_nulls: |
1065 | 1065 | return x.isnull() | x.isin(matchable_ibis_values) |
1066 | 1066 | else: |
1067 | | - return x.isin(matchable_ibis_values).fillna(False) |
| 1067 | + return x.isin(matchable_ibis_values).fill_null(ibis.literal(False)) |
1068 | 1068 |
|
1069 | 1069 |
|
1070 | 1070 | @scalar_op_compiler.register_unary_op(ops.ToDatetimeOp, pass_op=True) |
@@ -1383,8 +1383,8 @@ def eq_nulls_match_op( |
1383 | 1383 | left = x.cast(ibis_dtypes.str).fill_null(literal) |
1384 | 1384 | right = y.cast(ibis_dtypes.str).fill_null(literal) |
1385 | 1385 | else: |
1386 | | - left = x.cast(ibis_dtypes.str).fillna(literal) |
1387 | | - right = y.cast(ibis_dtypes.str).fillna(literal) |
| 1386 | + left = x.cast(ibis_dtypes.str).fill_null(literal) |
| 1387 | + right = y.cast(ibis_dtypes.str).fill_null(literal) |
1388 | 1388 |
|
1389 | 1389 | return left == right |
1390 | 1390 |
|
@@ -1813,7 +1813,7 @@ def fillna_op( |
1813 | 1813 | if hasattr(x, "fill_null"): |
1814 | 1814 | return x.fill_null(typing.cast(ibis_types.Scalar, y)) |
1815 | 1815 | else: |
1816 | | - return x.fillna(typing.cast(ibis_types.Scalar, y)) |
| 1816 | + return x.fill_null(typing.cast(ibis_types.Scalar, y)) |
1817 | 1817 |
|
1818 | 1818 |
|
1819 | 1819 | @scalar_op_compiler.register_binary_op(ops.round_op) |
@@ -2016,7 +2016,7 @@ def _construct_prompt( |
2016 | 2016 |
|
2017 | 2017 | @scalar_op_compiler.register_nary_op(ops.RowKey, pass_op=True) |
2018 | 2018 | def rowkey_op_impl(*values: ibis_types.Value, op: ops.RowKey) -> ibis_types.Value: |
2019 | | - return bigframes.core.compile.default_ordering.gen_row_key(values) |
| 2019 | + return bigframes.core.compile.ibis_compiler.default_ordering.gen_row_key(values) |
2020 | 2020 |
|
2021 | 2021 |
|
2022 | 2022 | # Helpers |
|
0 commit comments