diff options
| author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-03-03 14:11:07 +0000 |
|---|---|---|
| committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-03-03 14:11:07 +0000 |
| commit | 42a1548cecf48d18233f56e3385cf9c89abcb9c2 (patch) | |
| tree | 5e0fff4ecbd1fd7dd1022a7580139038df2a824c /sqlglot/dataframe/sql | |
| parent | Releasing debian version 21.1.2-1. (diff) | |
| download | sqlglot-42a1548cecf48d18233f56e3385cf9c89abcb9c2.tar.xz sqlglot-42a1548cecf48d18233f56e3385cf9c89abcb9c2.zip | |
Merging upstream version 22.2.0.
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'sqlglot/dataframe/sql')
| -rw-r--r-- | sqlglot/dataframe/sql/dataframe.py | 6 | ||||
| -rw-r--r-- | sqlglot/dataframe/sql/functions.py | 4 |
2 files changed, 4 insertions, 6 deletions
diff --git a/sqlglot/dataframe/sql/dataframe.py b/sqlglot/dataframe/sql/dataframe.py index 7e3f07b..0bacbf9 100644 --- a/sqlglot/dataframe/sql/dataframe.py +++ b/sqlglot/dataframe/sql/dataframe.py @@ -140,12 +140,10 @@ class DataFrame: return cte, name @t.overload - def _ensure_list_of_columns(self, cols: t.Collection[ColumnOrLiteral]) -> t.List[Column]: - ... + def _ensure_list_of_columns(self, cols: t.Collection[ColumnOrLiteral]) -> t.List[Column]: ... @t.overload - def _ensure_list_of_columns(self, cols: ColumnOrLiteral) -> t.List[Column]: - ... + def _ensure_list_of_columns(self, cols: ColumnOrLiteral) -> t.List[Column]: ... def _ensure_list_of_columns(self, cols): return Column.ensure_cols(ensure_list(cols)) diff --git a/sqlglot/dataframe/sql/functions.py b/sqlglot/dataframe/sql/functions.py index 308b639..db5201f 100644 --- a/sqlglot/dataframe/sql/functions.py +++ b/sqlglot/dataframe/sql/functions.py @@ -210,7 +210,7 @@ def sec(col: ColumnOrName) -> Column: def signum(col: ColumnOrName) -> Column: - return Column.invoke_anonymous_function(col, "SIGNUM") + return Column.invoke_expression_over_column(col, expression.Sign) def sin(col: ColumnOrName) -> Column: @@ -592,7 +592,7 @@ def date_diff(end: ColumnOrName, start: ColumnOrName) -> Column: def add_months(start: ColumnOrName, months: t.Union[ColumnOrName, int]) -> Column: - return Column.invoke_anonymous_function(start, "ADD_MONTHS", months) + return Column.invoke_expression_over_column(start, expression.AddMonths, expression=months) def months_between( |