| 227 | |
| 228 | public: |
| 229 | IntegerColumnReader(const Type& type, StripeStreams& stripe) : ColumnReader(type, stripe) { |
| 230 | RleVersion vers = convertRleVersion(stripe.getEncoding(columnId).kind()); |
| 231 | std::unique_ptr<SeekableInputStream> stream = |
| 232 | stripe.getStream(columnId, proto::Stream_Kind_DATA, true); |
| 233 | if (stream == nullptr) throw ParseError("DATA stream not found in Integer column"); |
| 234 | rle = createRleDecoder(std::move(stream), true, vers, memoryPool, metrics); |
| 235 | } |
| 236 | |
| 237 | ~IntegerColumnReader() override { |
| 238 | // PASS |
nothing calls this directly
no test coverage detected