diff options
| author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2023-07-06 07:28:09 +0000 |
|---|---|---|
| committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2023-07-06 07:28:09 +0000 |
| commit | 52f4a5e2260f3e5b919b4e270339afd670bf0b8a (patch) | |
| tree | 5ca419af0e2e409018492b82f5b9847f0112b5fb /sqlglot/dialects/spark2.py | |
| parent | Adding upstream version 16.7.7. (diff) | |
| download | sqlglot-upstream/17.2.0.tar.xz sqlglot-upstream/17.2.0.zip | |
Adding upstream version 17.2.0.upstream/17.2.0
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'sqlglot/dialects/spark2.py')
| -rw-r--r-- | sqlglot/dialects/spark2.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/sqlglot/dialects/spark2.py b/sqlglot/dialects/spark2.py index 3720b8d..afe2482 100644 --- a/sqlglot/dialects/spark2.py +++ b/sqlglot/dialects/spark2.py @@ -173,6 +173,8 @@ class Spark2(Hive): return pivot_column_names(aggregations, dialect="spark") class Generator(Hive.Generator): + QUERY_HINTS = True + TYPE_MAPPING = { **Hive.Generator.TYPE_MAPPING, exp.DataType.Type.TINYINT: "BYTE", @@ -203,7 +205,6 @@ class Spark2(Hive): exp.DayOfYear: rename_func("DAYOFYEAR"), exp.FileFormatProperty: lambda self, e: f"USING {e.name.upper()}", exp.From: transforms.preprocess([_unalias_pivot]), - exp.Hint: lambda self, e: f" /*+ {self.expressions(e).strip()} */", exp.LogicalAnd: rename_func("BOOL_AND"), exp.LogicalOr: rename_func("BOOL_OR"), exp.Map: _map_sql, |