reader
Classes for building the Reader tree.
Constructing a reader tree from the schema makes it easy to decouple the reader implementation from the schema.
The reader tree can be changed in such a way that the read schema is different, while respecting the read schema.
BinaryReader
Bases: Reader
Read a binary value.
First reads an integer, to get the length of the binary value, then reads the binary field itself.
Source code in pyiceberg/avro/reader.py
DateReader
DecimalReader
dataclass
Bases: Reader
Reads a value as a decimal.
Decimal bytes are decoded as signed short, int or long depending on the size of bytes.
Source code in pyiceberg/avro/reader.py
FixedReader
dataclass
Bases: Reader
Source code in pyiceberg/avro/reader.py
__len__()
IntegerReader
Bases: Reader
Longs and ints are encoded the same way, and there is no long in Python.
Source code in pyiceberg/avro/reader.py
ListReader
dataclass
Bases: Reader
Source code in pyiceberg/avro/reader.py
MapReader
dataclass
Bases: Reader
Source code in pyiceberg/avro/reader.py
398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 |
|
Reader
Bases: Singleton
Source code in pyiceberg/avro/reader.py
StructReader
Bases: Reader
Source code in pyiceberg/avro/reader.py
__eq__(other)
Return the equality of two instances of the StructReader class.
Source code in pyiceberg/avro/reader.py
__hash__()
__repr__()
Return the string representation of the StructReader class.
TimeReader
Bases: IntegerReader
Reads a microsecond granularity timestamp from the stream.
Long is decoded as an integer which represents the number of microseconds from the unix epoch, 1 January 1970.
TimestampReader
Bases: IntegerReader
Reads a microsecond granularity timestamp from the stream.
Long is decoded as python integer which represents the number of microseconds from the unix epoch, 1 January 1970.
TimestamptzReader
Bases: IntegerReader
Reads a microsecond granularity timestamptz from the stream.
Long is decoded as python integer which represents the number of microseconds from the unix epoch, 1 January 1970.
Adjusted to UTC.