We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d53e787 commit 00cc5edCopy full SHA for 00cc5ed
sqlmesh/core/engine_adapter/spark.py
@@ -105,6 +105,7 @@ def _sqlglot_to_spark_primitive_mapping(self) -> t.Dict[t.Any, t.Any]:
105
exp.DataType.Type.BINARY: spark_types.BinaryType,
106
exp.DataType.Type.BOOLEAN: spark_types.BooleanType,
107
exp.DataType.Type.DATE: spark_types.DateType,
108
+ exp.DataType.Type.TIMESTAMPNTZ: spark_types.TimestampNTZType,
109
exp.DataType.Type.DATETIME: spark_types.TimestampNTZType,
110
exp.DataType.Type.TIMESTAMPLTZ: spark_types.TimestampType,
111
exp.DataType.Type.TIMESTAMP: spark_types.TimestampType,
0 commit comments