| 461 | |
| 462 | template <typename BatchType> |
| 463 | IntegerColumnWriter<BatchType>::IntegerColumnWriter(const Type& type, |
| 464 | const StreamsFactory& factory, |
| 465 | const WriterOptions& options) |
| 466 | : ColumnWriter(type, factory, options), rleVersion_(options.getRleVersion()) { |
| 467 | std::unique_ptr<BufferedOutputStream> dataStream = |
| 468 | factory.createStream(proto::Stream_Kind_DATA); |
| 469 | rleEncoder = createRleEncoder(std::move(dataStream), true, rleVersion_, memPool, |
| 470 | options.getAlignedBitpacking()); |
| 471 | |
| 472 | if (enableIndex) { |
| 473 | recordPosition(); |
| 474 | } |
| 475 | } |
| 476 | |
| 477 | template <typename BatchType> |
| 478 | void IntegerColumnWriter<BatchType>::add(ColumnVectorBatch& rowBatch, uint64_t offset, |
nothing calls this directly
no test coverage detected