forked from facebookincubator/nimble
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Add getFileRawDataSize Test Utilities (facebookincubator#73)
Summary: Pull Request resolved: facebookincubator#73 # Changes Adding functions to the TestUtils.h in tests folders of both `encodings` and `velox` which allows us to calculate the raw data size of files by reading. - Note the special handling for Nullable encoding types and String data types in the `getRawChunkSize` function. # Context This is necessary to check the correctness of the raw data size stat added in the following diff, which calculates the size when writing. This change will also be used by nimble_dump later on (to be implemented in a later diff). Reviewed By: sdruzkin, helfman Differential Revision: D61050482
- Loading branch information
1 parent
6a53405
commit bbf1351
Showing
5 changed files
with
272 additions
and
6 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,138 @@ | ||
| /* | ||
| * Copyright (c) Meta Platforms, Inc. and its affiliates. | ||
| * | ||
| * Licensed under the Apache License, Version 2.0 (the "License"); | ||
| * you may not use this file except in compliance with the License. | ||
| * You may obtain a copy of the License at | ||
| * | ||
| * http://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * Unless required by applicable law or agreed to in writing, software | ||
| * distributed under the License is distributed on an "AS IS" BASIS, | ||
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| * See the License for the specific language governing permissions and | ||
| * limitations under the License. | ||
| */ | ||
|
|
||
| #include "dwio/nimble/encodings/tests/TestUtils.h" | ||
| #include "dwio/nimble/encodings/EncodingUtils.h" | ||
|
|
||
| namespace facebook::nimble::test { | ||
|
|
||
| static constexpr int kRowCountOffset = 2; | ||
| static constexpr int kPrefixSize = 6; | ||
| static constexpr int kCompressionTypeSize = 1; | ||
|
|
||
| uint64_t TestUtils::getRawDataSize( | ||
| velox::memory::MemoryPool& memoryPool, | ||
| std::string_view encodingStr) { | ||
| auto encoding = EncodingFactory::decode(memoryPool, encodingStr); | ||
| EncodingType encodingType = encoding->encodingType(); | ||
| DataType dataType = encoding->dataType(); | ||
| uint32_t rowCount = encoding->rowCount(); | ||
|
|
||
| if (encodingType == EncodingType::Sentinel) { | ||
| NIMBLE_NOT_SUPPORTED("Sentinel encoding is not supported"); | ||
| } | ||
|
|
||
| if (encodingType == EncodingType::Nullable) { | ||
| auto pos = encodingStr.data() + kPrefixSize; | ||
| auto nonNullsSize = encoding::readUint32(pos); | ||
| auto nonNullsCount = encoding::peek<uint32_t>(pos + kRowCountOffset); | ||
| // We do not count the bits indicating non-null, therefore we only | ||
| // include the size of the null bits and the non-null values. | ||
| return getRawDataSize(memoryPool, {pos, nonNullsSize}) + | ||
| (rowCount - nonNullsCount); | ||
| } else { | ||
| if (dataType != DataType::String) { | ||
| auto typeSize = nimble::detail::dataTypeSize(dataType); | ||
| auto result = typeSize * rowCount; | ||
| return result; | ||
| } else { | ||
| auto pos = encodingStr.data() + kPrefixSize; // Skip the prefix. | ||
| uint64_t result = 0; | ||
|
|
||
| switch (encodingType) { | ||
| case EncodingType::Trivial: { | ||
| pos += kCompressionTypeSize; | ||
| auto lengthsSize = encoding::readUint32(pos); | ||
| auto lengths = | ||
| EncodingFactory::decode(memoryPool, {pos, lengthsSize}); | ||
| std::vector<uint32_t> buffer(rowCount); | ||
| lengths->materialize(rowCount, buffer.data()); | ||
| result += std::accumulate(buffer.begin(), buffer.end(), 0); | ||
| break; | ||
| } | ||
|
|
||
| case EncodingType::Constant: { | ||
| auto valueSize = encoding::readUint32(pos); | ||
| result += rowCount * valueSize; | ||
| break; | ||
| } | ||
|
|
||
| case EncodingType::MainlyConstant: { | ||
| auto isCommonSize = encoding::readUint32(pos); | ||
| pos += isCommonSize; | ||
| auto otherValuesSize = encoding::readUint32(pos); | ||
| auto otherValuesOffset = pos; | ||
| auto otherValuesCount = | ||
| encoding::peek<uint32_t>(pos + kRowCountOffset); | ||
| pos += otherValuesSize; | ||
| auto constantValueSize = encoding::readUint32(pos); | ||
| result += (rowCount - otherValuesCount) * constantValueSize; | ||
| result += | ||
| getRawDataSize(memoryPool, {otherValuesOffset, otherValuesSize}); | ||
| break; | ||
| } | ||
|
|
||
| case EncodingType::Dictionary: { | ||
| auto alphabetSize = encoding::readUint32(pos); | ||
| auto alphabetCount = encoding::peek<uint32_t>(pos + kRowCountOffset); | ||
| auto alphabet = | ||
| EncodingFactory::decode(memoryPool, {pos, alphabetSize}); | ||
| std::vector<std::string_view> alphabetBuffer(alphabetCount); | ||
| alphabet->materialize(alphabetCount, alphabetBuffer.data()); | ||
|
|
||
| pos += alphabetSize; | ||
| auto indicesSize = encodingStr.length() - (pos - encodingStr.data()); | ||
| auto indices = | ||
| EncodingFactory::decode(memoryPool, {pos, indicesSize}); | ||
| std::vector<uint32_t> indicesBuffer(rowCount); | ||
| indices->materialize(rowCount, indicesBuffer.data()); | ||
| for (int i = 0; i < rowCount; ++i) { | ||
| result += alphabetBuffer[indicesBuffer[i]].size(); | ||
| } | ||
| break; | ||
| } | ||
|
|
||
| case EncodingType::RLE: { | ||
| auto runLengthsSize = encoding::readUint32(pos); | ||
| auto runLengthsCount = | ||
| encoding::peek<uint32_t>(pos + kRowCountOffset); | ||
| auto runLengths = | ||
| EncodingFactory::decode(memoryPool, {pos, runLengthsSize}); | ||
| std::vector<uint32_t> runLengthsBuffer(runLengthsCount); | ||
| runLengths->materialize(runLengthsCount, runLengthsBuffer.data()); | ||
|
|
||
| pos += runLengthsSize; | ||
| auto runValuesSize = | ||
| encodingStr.length() - (pos - encodingStr.data()); | ||
| auto runValues = | ||
| EncodingFactory::decode(memoryPool, {pos, runValuesSize}); | ||
| std::vector<std::string_view> runValuesBuffer(runLengthsCount); | ||
| runValues->materialize(runLengthsCount, runValuesBuffer.data()); | ||
|
|
||
| for (int i = 0; i < runLengthsCount; ++i) { | ||
| result += runLengthsBuffer[i] * runValuesBuffer[i].size(); | ||
| } | ||
| break; | ||
| } | ||
|
|
||
| default: | ||
| NIMBLE_NOT_SUPPORTED("Encoding type does not support strings."); | ||
| } | ||
| return result; | ||
| } | ||
| } | ||
| } | ||
| } // namespace facebook::nimble::test |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.