| 1 | #pragma once |
| 2 | |
| 3 | #include <optional> |
| 4 | #include <Core/Types.h> |
| 5 | |
| 6 | namespace DB |
| 7 | { |
| 8 | |
| 9 | class MergeTreeData; |
| 10 | /// Meta information about index granularity |
| 11 | struct MergeTreeIndexGranularityInfo |
| 12 | { |
| 13 | public: |
| 14 | /// Marks file extension '.mrk' or '.mrk2' |
| 15 | String marks_file_extension; |
| 16 | |
| 17 | /// Size of one mark in file two or three size_t numbers |
| 18 | UInt8 mark_size_in_bytes; |
| 19 | |
| 20 | /// Is stride in rows between marks non fixed? |
| 21 | bool is_adaptive; |
| 22 | |
| 23 | /// Fixed size in rows of one granule if index_granularity_bytes is zero |
| 24 | size_t fixed_index_granularity; |
| 25 | |
| 26 | /// Approximate bytes size of one granule |
| 27 | size_t index_granularity_bytes; |
| 28 | |
| 29 | MergeTreeIndexGranularityInfo( |
| 30 | const MergeTreeData & storage); |
| 31 | |
| 32 | void changeGranularityIfRequired(const std::string & path_to_part); |
| 33 | |
| 34 | String getMarksFilePath(const String & column_path) const |
| 35 | { |
| 36 | return column_path + marks_file_extension; |
| 37 | } |
| 38 | private: |
| 39 | |
| 40 | void setAdaptive(size_t index_granularity_bytes_); |
| 41 | void setNonAdaptive(); |
| 42 | std::optional<std::string> getMrkExtensionFromFS(const std::string & path_to_table) const; |
| 43 | }; |
| 44 | |
| 45 | constexpr inline auto getNonAdaptiveMrkExtension() { return ".mrk" ; } |
| 46 | constexpr inline auto getAdaptiveMrkExtension() { return ".mrk2" ; } |
| 47 | constexpr inline auto getNonAdaptiveMrkSize() { return sizeof(UInt64) * 2; } |
| 48 | constexpr inline auto getAdaptiveMrkSize() { return sizeof(UInt64) * 3; } |
| 49 | |
| 50 | } |
| 51 | |