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()