feat(schema conversion): add schema conversion from avro timestamp-millis

Author: matthias-Q

pyiceberg/utils/schema_conversion.py

@@ -69,6 +69,7 @@
 LOGICAL_FIELD_TYPE_MAPPING: Dict[Tuple[str, str], PrimitiveType] = {
     ("date", "int"): DateType(),
     ("time-micros", "long"): TimeType(),
+    ("timestamp-millis", "int"): TimestampType(),
     ("timestamp-micros", "long"): TimestampType(),
     ("uuid", "fixed"): UUIDType(),
 }

tests/utils/test_schema_conversion.py

@@ -33,6 +33,7 @@
     NestedField,
     StringType,
     StructType,
+    TimestampType,
     UnknownType,
 )
 from pyiceberg.utils.schema_conversion import AvroSchemaConversion
@@ -327,6 +328,18 @@ def test_convert_date_type() -> None:
     assert actual == DateType()
 
 
+def test_convert_timestamp_millis_type() -> None:
+    avro_logical_type = {"type": "int", "logicalType": "timestamp-millis"}
+    actual = AvroSchemaConversion()._convert_logical_type(avro_logical_type)
+    assert actual == TimestampType()
+
+
+def test_convert_timestamp_micros_type() -> None:
+    avro_logical_type = {"type": "int", "logicalType": "timestamp-micros"}
+    actual = AvroSchemaConversion()._convert_logical_type(avro_logical_type)
+    assert actual == TimestampType()
+
+
 def test_unknown_logical_type() -> None:
     """Test raising a ValueError when converting an unknown logical type as part of an Avro schema conversion"""
     avro_logical_type = {"type": "bytes", "logicalType": "date"}