diff options
| author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-02-08 05:38:39 +0000 |
|---|---|---|
| committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-02-08 05:38:39 +0000 |
| commit | aedf35026379f52d7e2b4c1f957691410a758089 (patch) | |
| tree | 86540364259b66741173d2333387b78d6f9c31e2 /tests/dataframe/unit | |
| parent | Adding upstream version 20.11.0. (diff) | |
| download | sqlglot-aedf35026379f52d7e2b4c1f957691410a758089.tar.xz sqlglot-aedf35026379f52d7e2b4c1f957691410a758089.zip | |
Adding upstream version 21.0.1.upstream/21.0.1
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'tests/dataframe/unit')
| -rw-r--r-- | tests/dataframe/unit/test_functions.py | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/tests/dataframe/unit/test_functions.py b/tests/dataframe/unit/test_functions.py index c845441..24904b7 100644 --- a/tests/dataframe/unit/test_functions.py +++ b/tests/dataframe/unit/test_functions.py @@ -528,7 +528,7 @@ class TestFunctions(unittest.TestCase): col = SF.first(SF.col("cola")) self.assertEqual("FIRST(cola)", col.sql()) ignore_nulls = SF.first("cola", True) - self.assertEqual("FIRST(cola, TRUE)", ignore_nulls.sql()) + self.assertEqual("FIRST(cola) IGNORE NULLS", ignore_nulls.sql()) def test_grouping_id(self): col_str = SF.grouping_id("cola", "colb") @@ -562,7 +562,7 @@ class TestFunctions(unittest.TestCase): col = SF.last(SF.col("cola")) self.assertEqual("LAST(cola)", col.sql()) ignore_nulls = SF.last("cola", True) - self.assertEqual("LAST(cola, TRUE)", ignore_nulls.sql()) + self.assertEqual("LAST(cola) IGNORE NULLS", ignore_nulls.sql()) def test_monotonically_increasing_id(self): col = SF.monotonically_increasing_id() @@ -713,8 +713,10 @@ class TestFunctions(unittest.TestCase): self.assertEqual("NTH_VALUE(cola, 3)", col.sql()) col_no_offset = SF.nth_value("cola") self.assertEqual("NTH_VALUE(cola)", col_no_offset.sql()) - with self.assertRaises(NotImplementedError): - SF.nth_value("cola", ignoreNulls=True) + + self.assertEqual( + "NTH_VALUE(cola) IGNORE NULLS", SF.nth_value("cola", ignoreNulls=True).sql() + ) def test_ntile(self): col = SF.ntile(2) |