You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by bl...@apache.org on 2022/10/13 18:25:35 UTC
[iceberg] branch master updated: Python: Fix incorrect annotation, StringType to BinaryType (#5950)
This is an automated email from the ASF dual-hosted git repository.
blue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git
The following commit(s) were added to refs/heads/master by this push:
new 468e99871e Python: Fix incorrect annotation, StringType to BinaryType (#5950)
468e99871e is described below
commit 468e99871ea661dbe7b365e38c101e36971c525b
Author: Fokko Driesprong <fo...@apache.org>
AuthorDate: Thu Oct 13 20:25:29 2022 +0200
Python: Fix incorrect annotation, StringType to BinaryType (#5950)
---
python/pyiceberg/avro/reader.py | 28 ++++++++++++++--------------
1 file changed, 14 insertions(+), 14 deletions(-)
diff --git a/python/pyiceberg/avro/reader.py b/python/pyiceberg/avro/reader.py
index 247cf1c3ad..3de1105575 100644
--- a/python/pyiceberg/avro/reader.py
+++ b/python/pyiceberg/avro/reader.py
@@ -355,68 +355,68 @@ def primitive_reader(primitive: PrimitiveType) -> Reader:
raise ValueError(f"Unknown type: {primitive}")
-@primitive_reader.register(FixedType)
+@primitive_reader.register
def _(primitive: FixedType) -> Reader:
return FixedReader(primitive.length)
-@primitive_reader.register(DecimalType)
+@primitive_reader.register
def _(primitive: DecimalType) -> Reader:
return DecimalReader(primitive.precision, primitive.scale)
-@primitive_reader.register(BooleanType)
+@primitive_reader.register
def _(_: BooleanType) -> Reader:
return BooleanReader()
-@primitive_reader.register(IntegerType)
+@primitive_reader.register
def _(_: IntegerType) -> Reader:
return IntegerReader()
-@primitive_reader.register(LongType)
+@primitive_reader.register
def _(_: LongType) -> Reader:
# Ints and longs are encoded the same way in Python and
# also binary compatible in Avro
return IntegerReader()
-@primitive_reader.register(FloatType)
+@primitive_reader.register
def _(_: FloatType) -> Reader:
return FloatReader()
-@primitive_reader.register(DoubleType)
+@primitive_reader.register
def _(_: DoubleType) -> Reader:
return DoubleReader()
-@primitive_reader.register(DateType)
+@primitive_reader.register
def _(_: DateType) -> Reader:
return DateReader()
-@primitive_reader.register(TimeType)
+@primitive_reader.register
def _(_: TimeType) -> Reader:
return TimeReader()
-@primitive_reader.register(TimestampType)
+@primitive_reader.register
def _(_: TimestampType) -> Reader:
return TimestampReader()
-@primitive_reader.register(TimestamptzType)
+@primitive_reader.register
def _(_: TimestamptzType) -> Reader:
return TimestamptzReader()
-@primitive_reader.register(StringType)
+@primitive_reader.register
def _(_: StringType) -> Reader:
return StringReader()
-@primitive_reader.register(BinaryType)
-def _(_: StringType) -> Reader:
+@primitive_reader.register
+def _(_: BinaryType) -> Reader:
return BinaryReader()