| 93 | |
| 94 | template<std::floating_point T> |
| 95 | ColumnChunkMetadata compressBuffer(const std::vector<T>& bufferToCompress, |
| 96 | const std::shared_ptr<FloatCompression<T>>& alg, const CompressionMetadata* metadata, |
| 97 | FileHandle* dataFH, const LogicalType& dataType) { |
| 98 | |
| 99 | auto preScanMetadata = GetFloatCompressionMetadata<T>{alg, dataType}.operator()( |
| 100 | byteSpan(bufferToCompress), bufferToCompress.size(), metadata->min, metadata->max); |
| 101 | auto allocatedBlock = |
| 102 | dataFH->getPageManager()->allocatePageRange(preScanMetadata.getNumPages()); |
| 103 | |
| 104 | if (preScanMetadata.compMeta.compression == CompressionType::CONSTANT) { |
| 105 | return preScanMetadata; |
| 106 | } |
| 107 | |
| 108 | return CompressedFloatFlushBuffer<T>{alg, dataType}.operator()(byteSpan(bufferToCompress), |
| 109 | dataFH, allocatedBlock, preScanMetadata); |
| 110 | } |
| 111 | |
| 112 | template<std::floating_point T> |
| 113 | void CompressChunkTest::commitUpdate(SegmentState& state, FileHandle* dataFH, |
no test coverage detected