diff --git a/src/storage/store/column_chunk.cpp b/src/storage/store/column_chunk.cpp index 9ad52f75d2..c2711e1483 100644 --- a/src/storage/store/column_chunk.cpp +++ b/src/storage/store/column_chunk.cpp @@ -121,6 +121,7 @@ ColumnChunk::ColumnChunk( GetCompressionMetadata(std::make_unique>(), this->dataType); break; } + case PhysicalTypeID::VAR_LIST: case PhysicalTypeID::UINT64: { flushBufferFunction = CompressedFlushBuffer(std::make_unique>(), this->dataType); diff --git a/src/storage/store/compression.cpp b/src/storage/store/compression.cpp index e17997f537..cf625e3e33 100644 --- a/src/storage/store/compression.cpp +++ b/src/storage/store/compression.cpp @@ -84,6 +84,7 @@ bool CompressionMetadata::canUpdateInPlace( return IntegerBitpacking::canUpdateInPlace( value, BitpackHeader::readHeader(data)); } + case PhysicalTypeID::VAR_LIST: case PhysicalTypeID::UINT64: { auto value = vector.getValue(pos); return IntegerBitpacking::canUpdateInPlace( @@ -120,6 +121,7 @@ uint64_t CompressionMetadata::numValues(uint64_t pageSize, const LogicalType& da return IntegerBitpacking::numValues(pageSize, BitpackHeader::readHeader(data)); case PhysicalTypeID::INT32: return IntegerBitpacking::numValues(pageSize, BitpackHeader::readHeader(data)); + case PhysicalTypeID::VAR_LIST: case PhysicalTypeID::UINT64: return IntegerBitpacking::numValues(pageSize, BitpackHeader::readHeader(data)); case PhysicalTypeID::UINT32: @@ -382,6 +384,7 @@ void ReadCompressedValuesFromPageToVector::operator()(uint8_t* frame, PageElemen return IntegerBitpacking().decompressFromPage(frame, pageCursor.elemPosInPage, resultVector->getData(), posInVector, numValuesToRead, metadata); } + case PhysicalTypeID::VAR_LIST: case PhysicalTypeID::UINT64: { return IntegerBitpacking().decompressFromPage(frame, pageCursor.elemPosInPage, resultVector->getData(), posInVector, numValuesToRead, metadata); @@ -419,6 +422,7 @@ void ReadCompressedValuesFromPage::operator()(uint8_t* frame, PageElementCursor& return IntegerBitpacking().decompressFromPage(frame, pageCursor.elemPosInPage, result, startPosInResult, numValuesToRead, metadata); } + case PhysicalTypeID::VAR_LIST: case PhysicalTypeID::UINT64: { return IntegerBitpacking().decompressFromPage(frame, pageCursor.elemPosInPage, result, startPosInResult, numValuesToRead, metadata); @@ -455,6 +459,7 @@ void WriteCompressedValueToPage::operator()(uint8_t* frame, uint16_t posInFrame, return IntegerBitpacking().setValueFromUncompressed( vector->getData(), posInVector, frame, posInFrame, metadata); } + case PhysicalTypeID::VAR_LIST: case PhysicalTypeID::UINT64: { return IntegerBitpacking().setValueFromUncompressed( vector->getData(), posInVector, frame, posInFrame, metadata);