diff options
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, |