#pragma once #include #include #include #include #include #include #include #include #include #include #include #include /** This dictionary stores all attributes in arrays. * Key is stored in hash table and value is index into attribute array. */ namespace DB { struct HashedArrayDictionaryStorageConfiguration { const bool require_nonempty; const DictionaryLifetime lifetime; }; template class HashedArrayDictionary final : public IDictionary { public: using KeyType = std::conditional_t; HashedArrayDictionary( const StorageID & dict_id_, const DictionaryStructure & dict_struct_, DictionarySourcePtr source_ptr_, const HashedArrayDictionaryStorageConfiguration & configuration_, BlockPtr update_field_loaded_block_ = nullptr); std::string getTypeName() const override { if constexpr (dictionary_key_type == DictionaryKeyType::Simple) return "HashedArray"; else return "ComplexHashedArray"; } size_t getBytesAllocated() const override { return bytes_allocated; } size_t getQueryCount() const override { return query_count.load(std::memory_order_relaxed); } double getFoundRate() const override { size_t queries = query_count.load(std::memory_order_relaxed); if (!queries) return 0; return static_cast(found_count.load(std::memory_order_relaxed)) / queries; } double getHitRate() const override { return 1.0; } size_t getElementCount() const override { return element_count; } double getLoadFactor() const override { return static_cast(element_count) / bucket_count; } std::shared_ptr clone() const override { return std::make_shared>(getDictionaryID(), dict_struct, source_ptr->clone(), configuration, update_field_loaded_block); } const IDictionarySource * getSource() const override { return source_ptr.get(); } const DictionaryLifetime & getLifetime() const override { return configuration.lifetime; } const DictionaryStructure & getStructure() const override { return dict_struct; } bool isInjective(const std::string & attribute_name) const override { return dict_struct.getAttribute(attribute_name).injective; } DictionaryKeyType getKeyType() const override { return dictionary_key_type; } ColumnPtr getColumn( const std::string& attribute_name, const DataTypePtr & result_type, const Columns & key_columns, const DataTypes & key_types, const ColumnPtr & default_values_column) const override; ColumnUInt8::Ptr hasKeys(const Columns & key_columns, const DataTypes & key_types) const override; bool hasHierarchy() const override { return dictionary_key_type == DictionaryKeyType::Simple && dict_struct.hierarchical_attribute_index.has_value(); } ColumnPtr getHierarchy(ColumnPtr key_column, const DataTypePtr & hierarchy_attribute_type) const override; ColumnUInt8::Ptr isInHierarchy( ColumnPtr key_column, ColumnPtr in_key_column, const DataTypePtr & key_type) const override; ColumnPtr getDescendants( ColumnPtr key_column, const DataTypePtr & key_type, size_t level) const override; Pipe read(const Names & column_names, size_t max_block_size) const override; private: using KeyContainerType = std::conditional_t< dictionary_key_type == DictionaryKeyType::Simple, HashMap, HashMapWithSavedHash>>; template using AttributeContainerType = std::conditional_t, std::vector, PaddedPODArray>; struct Attribute final { AttributeUnderlyingType type; std::variant< AttributeContainerType, AttributeContainerType, AttributeContainerType, AttributeContainerType, AttributeContainerType, AttributeContainerType, AttributeContainerType, AttributeContainerType, AttributeContainerType, AttributeContainerType, AttributeContainerType, AttributeContainerType, AttributeContainerType, AttributeContainerType, AttributeContainerType, AttributeContainerType, AttributeContainerType, AttributeContainerType, AttributeContainerType, AttributeContainerType, AttributeContainerType> container; std::optional> is_index_null; std::unique_ptr string_arena; }; struct KeyAttribute final { KeyContainerType container; }; void createAttributes(); void blockToAttributes(const Block & block); void updateData(); void loadData(); void calculateBytesAllocated(); template void getItemsImpl( const Attribute & attribute, DictionaryKeysExtractor & keys_extractor, ValueSetter && set_value, DefaultValueExtractor & default_value_extractor) const; template void getAttributeContainer(size_t attribute_index, GetContainerFunc && get_container_func); template void getAttributeContainer(size_t attribute_index, GetContainerFunc && get_container_func) const; void resize(size_t added_rows); StringRef copyKeyInArena(StringRef key); const DictionaryStructure dict_struct; const DictionarySourcePtr source_ptr; const HashedArrayDictionaryStorageConfiguration configuration; std::vector attributes; KeyAttribute key_attribute; size_t bytes_allocated = 0; size_t element_count = 0; size_t bucket_count = 0; mutable std::atomic query_count{0}; mutable std::atomic found_count{0}; BlockPtr update_field_loaded_block; Arena complex_key_arena; }; extern template class HashedArrayDictionary; extern template class HashedArrayDictionary; }