diff options
| author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2023-10-10 08:53:14 +0000 |
|---|---|---|
| committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2023-10-10 08:53:14 +0000 |
| commit | cd37a3bcaced9283c20baa52837c96b524baec54 (patch) | |
| tree | 101b1c1487aa832a982dd635cd3b00d4d2ea3ae9 /sqlglot/dialects/spark2.py | |
| parent | Releasing progress-linux version 18.11.2-1. (diff) | |
| download | sqlglot-cd37a3bcaced9283c20baa52837c96b524baec54.tar.xz sqlglot-cd37a3bcaced9283c20baa52837c96b524baec54.zip | |
Merging upstream version 18.11.6.
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'sqlglot/dialects/spark2.py')
| -rw-r--r-- | sqlglot/dialects/spark2.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/sqlglot/dialects/spark2.py b/sqlglot/dialects/spark2.py index 4130375..2fd4f4e 100644 --- a/sqlglot/dialects/spark2.py +++ b/sqlglot/dialects/spark2.py @@ -117,6 +117,10 @@ class Spark2(Hive): "DAYOFYEAR": lambda args: exp.DayOfYear(this=exp.TsOrDsToDate(this=seq_get(args, 0))), "DOUBLE": _parse_as_cast("double"), "FLOAT": _parse_as_cast("float"), + "FROM_UTC_TIMESTAMP": lambda args: exp.AtTimeZone( + this=exp.Cast(this=seq_get(args, 0), to=exp.DataType.build("timestamp")), + zone=seq_get(args, 1), + ), "IIF": exp.If.from_arg_list, "INT": _parse_as_cast("int"), "MAP_FROM_ARRAYS": exp.Map.from_arg_list, |