| 3689 | } |
| 3690 | |
| 3691 | void PrestoVectorSerde::deserialize( |
| 3692 | ByteInputStream* source, |
| 3693 | bolt::memory::MemoryPool* pool, |
| 3694 | RowTypePtr type, |
| 3695 | RowVectorPtr* result, |
| 3696 | vector_size_t resultOffset, |
| 3697 | const Options* options) { |
| 3698 | const auto prestoOptions = toPrestoOptions(options); |
| 3699 | const bool useLosslessTimestamp = prestoOptions.useLosslessTimestamp; |
| 3700 | const auto codec = |
| 3701 | common::compressionKindToCodec(prestoOptions.compressionKind); |
| 3702 | const auto numRows = source->read<int32_t>(); |
| 3703 | auto pageCodecMarker = source->read<int8_t>(); |
| 3704 | #ifndef BOLT_ENABLE_CRC |
| 3705 | BOLT_CHECK_EQ( |
| 3706 | pageCodecMarker & kCheckSumBitMask, |
nothing calls this directly
no test coverage detected