Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion src/algorithm/bruteforce/bruteforce_parameter.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@

#include "bruteforce_parameter.h"

#include <fmt/format.h>
#include <fmt/core.h>

#include "datacell/flatten_datacell_parameter.h"
#include "impl/logger/logger.h"
Expand Down
41 changes: 26 additions & 15 deletions src/algorithm/hgraph/hgraph.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -14,39 +14,50 @@

#include "hgraph.h"

#include <datacell/compressed_graph_datacell_parameter.h>
#include <fmt/format.h>
#include <fmt/core.h>

#include <algorithm>
#include <atomic>
#include <cmath>
#include <cstdint>
#include <cstdlib>
#include <memory>
#include <mutex>
#include <stdexcept>

#include "algorithm/hgraph/hgraph_cache.h"
#include "algorithm/hgraph/hgraph_parameter.h"
#include "algorithm/inner_index_interface.h"
#include "algorithm/inner_index_parameter.h"
#include "analyzer/analyzer.h"
#include "attr/argparse.h"
#include "common.h"
#include "datacell/attribute_inverted_interface.h"
#include "datacell/extra_info_interface.h"
#include "datacell/flatten_interface.h"
#include "datacell/flatten_interface_parameter.h"
#include "datacell/sparse_graph_datacell.h"
#include "dataset_impl.h"
#include "impl/filter/filter_headers.h"
#include "impl/heap/standard_heap.h"
#include "impl/basic_optimizer.h"
#include "impl/label_table/label_table.h"
#include "impl/odescent/odescent_graph_builder.h"
#include "impl/odescent/odescent_graph_parameter.h"
#include "impl/pruning_strategy.h"
#include "impl/reasoning/search_reasoning.h"
#include "impl/reorder/flatten_reorder.h"
#include "index/index_impl.h"
#include "index/iterator_filter.h"
#include "index_common_param.h"
#include "index_feature_list.h"
#include "io/io_parameter.h"
#include "io/reader_io_parameter.h"
#include "storage/serialization.h"
#include "storage/stream_reader.h"
#include "typing.h"
#include "json_wrapper.h"
#include "tsl/robin_hash.h"
#include "utils/resource_object_pool.h"
#include "utils/util_functions.h"
#include "utils/visited_list.h"
#include "vsag/constants.h"
#include "vsag/index_features.h"
#include "vsag/options.h"
#include "vsag/search_request.h"

namespace vsag {

class HGraphAnalyzer;
class Reader;
struct AttributeSet;

HGraph::HGraph(const HGraphParameterPtr& hgraph_param, const vsag::IndexCommonParam& common_param)
: InnerIndexInterface(hgraph_param, common_param),
Expand Down
57 changes: 54 additions & 3 deletions src/algorithm/hgraph/hgraph_build.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -12,32 +12,83 @@
// See the License for the specific language governing permissions and
// limitations under the License.

#include <fmt/format.h>
#include <cxxabi.h>
#include <fmt/core.h>

#include <algorithm>
#include <atomic>
#include <chrono>
#include <cstdint>
#include <cstdlib>
#include <exception>
#include <fstream>
#include <future>
#include <iosfwd>
#include <limits>
#include <memory>
#include <mutex>
#include <shared_mutex>
#include <string>
#include <string_view>
#include <unordered_map>
#include <unordered_set>

#include <utility>
#include <vector>

#include "algorithm/hgraph/hgraph_cache.h"
#include "algorithm/hgraph/hgraph_parameter.h"
#include "algorithm/inner_index_interface.h"
#include "basic_types.h"
#include "common.h"
#include "container_types.h"
#include "data_type.h"
#include "datacell/attribute_inverted_interface.h"
#include "datacell/extra_info_interface.h"
#include "datacell/flatten_datacell_parameter.h"
#include "dataset_impl.h"
#include "datacell/flatten_interface.h"
#include "datacell/graph_interface.h"
#include "hash_types.h"
#include "hgraph.h" // IWYU pragma: keep
#include "impl/basic_optimizer.h"
#include "impl/heap/distance_heap.h"
#include "impl/heap/standard_heap.h"
#include "impl/inner_search_param.h"
#include "impl/label_table/label_table.h"
#include "impl/logger/logger.h"
#include "impl/odescent/odescent_graph_builder.h"
#include "impl/odescent/odescent_graph_parameter.h"
#include "impl/pruning_strategy.h"
#include "impl/reorder/flatten_reorder.h"
#include "impl/reorder/reorder.h"
#include "impl/runtime_parameter.h"
#include "impl/searcher/basic_searcher.h"
#include "impl/thread_pool/safe_thread_pool.h"
#include "index_common_param.h"
#include "index_feature_list.h"
#include "inner_string_params.h"
#include "io/io_parameter.h"
#include "io/memory_io_parameter.h"
#include "metric_type.h"
#include "quantization/quantizer_parameter.h"
#include "quantization/scalar_quantization/scalar_quantizer_parameter.h"
#include "storage/stream_reader.h"
#include "storage/stream_writer.h"
#include "tsl/robin_hash.h"
#include "tsl/robin_map.h"
#include "tsl/robin_set.h"
#include "utils/lock_strategy.h"
#include "utils/util_functions.h"
#include "utils/visited_list.h"
#include "vsag/attribute.h"
#include "vsag/constants.h"
#include "vsag/dataset.h"
#include "vsag/index.h"
#include "vsag/index_features.h"

namespace vsag {
class Allocator;
class IteratorFilterContext;
struct QueryContext;

static FlattenInterfacePtr
make_temporary_sq8_flatten(MetricType metric,
Expand Down
8 changes: 7 additions & 1 deletion src/algorithm/hgraph/hgraph_cache.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -14,9 +14,15 @@

#include "hgraph_cache.h"

#include "impl/allocator/default_allocator.h"
#include <cstdint>
#include <utility>

#include "storage/stream_reader.h"
#include "storage/stream_writer.h"
#include "tsl/robin_hash.h"

namespace vsag {
class Allocator;

HGraphCache::HGraphCache(Allocator* allocator)
: allocator_(allocator), source_ids_(allocator_), neighbors_(allocator_) {
Expand Down
26 changes: 25 additions & 1 deletion src/algorithm/hgraph/hgraph_modify.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -12,11 +12,35 @@
// See the License for the specific language governing permissions and
// limitations under the License.

#include <atomic>
#include <cstdint>
#include <memory>
#include <mutex>
#include <ostream>
#include <shared_mutex>
#include <tuple>
#include <vector>

#include "algorithm/inner_index_interface.h"
#include "basic_types.h"
#include "common.h"
#include "container_types.h"
#include "datacell/attribute_inverted_interface.h"
#include "datacell/extra_info_interface.h"
#include "datacell/flatten_interface.h"
#include "datacell/graph_interface.h"
#include "hash_types.h"
#include "hgraph.h" // IWYU pragma: keep
#include "impl/label_table/label_table.h"
#include "impl/pruning_strategy.h"
#include "utils/util_functions.h"
#include "tsl/robin_hash.h"
#include "utils/lock_strategy.h"
#include "vsag/errors.h"
#include "vsag/index.h"
#include "vsag_exception.h"

namespace vsag {
struct AttributeSet;

uint32_t
HGraph::Remove(const std::vector<int64_t>& ids, RemoveMode mode) {
Expand Down
17 changes: 16 additions & 1 deletion src/algorithm/hgraph/hgraph_param_mapping.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -12,11 +12,26 @@
// See the License for the specific language governing permissions and
// limitations under the License.

#include <fmt/format.h>
#include <fmt/core.h>

#include <algorithm>
#include <cstdint>
#include <memory>
#include <string>

#include "common.h"
#include "data_type.h"
#include "datacell/graph_interface_parameter.h"
#include "hgraph.h" // IWYU pragma: keep
#include "hgraph_parameter.h"
#include "index_common_param.h"
#include "inner_string_params.h"
#include "json_types.h"
#include "json_wrapper.h"
#include "parameter.h"
#include "type_helpers.h"
#include "utils/util_functions.h"
#include "vsag/constants.h"

namespace vsag {

Expand Down
2 changes: 1 addition & 1 deletion src/algorithm/hgraph/hgraph_parameter_test.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@

#include "hgraph_parameter.h"

#include <fmt/format.h>
#include <fmt/core.h>

#include "hgraph.h"
#include "index_common_param.h"
Expand Down
53 changes: 49 additions & 4 deletions src/algorithm/hgraph/hgraph_search.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -12,18 +12,63 @@
// See the License for the specific language governing permissions and
// limitations under the License.

#include <fmt/format.h>

#include <fmt/core.h>

#include <algorithm>
#include <atomic>
#include <cstddef>
#include <cstdint>
#include <limits>
#include <memory>
#include <ostream>
#include <shared_mutex>
#include <string>
#include <tuple>
#include <utility>
#include <vector>

#include "algorithm/hgraph/hgraph_parameter.h"
#include "algorithm/inner_index_interface.h"
#include "attr/argparse.h"
#include "attr/executor/executor.h"
#include "basic_types.h"
#include "common.h"
#include "container_types.h"
#include "data_type.h"
#include "datacell/attribute_inverted_interface.h"
#include "datacell/extra_info_interface.h"
#include "datacell/flatten_interface.h"
#include "datacell/graph_interface.h"
#include "dataset_impl.h"
#include "hash_types.h"
#include "hgraph.h" // IWYU pragma: keep
#include "impl/filter/filter_headers.h"
#include "impl/heap/standard_heap.h"
#include "impl/filter/combined_filter.h"
#include "impl/filter/extrainfo_wrapper_filter.h"
#include "impl/filter/inner_id_wrapper_filter.h"
#include "impl/heap/distance_heap.h"
#include "impl/inner_search_param.h"
#include "impl/label_table/label_table.h"
#include "impl/logger/logger.h"
#include "impl/reasoning/search_reasoning.h"
#include "impl/searcher/basic_searcher.h"
#include "impl/searcher/parallel_searcher.h"
#include "index/iterator_filter.h"
#include "query_context.h"
#include "tsl/robin_hash.h"
#include "utils/resource_object_pool.h"
#include "utils/timer.h"
#include "utils/util_functions.h"
#include "utils/visited_list.h"
#include "vsag/allocator.h"
#include "vsag/dataset.h"
#include "vsag/errors.h"
#include "vsag/expected.hpp"
#include "vsag/filter.h"
#include "vsag/search_request.h"
#include "vsag_exception.h"

namespace vsag {
class IteratorContext;

static DatasetPtr
make_empty_dataset_with_stats() {
Expand Down
40 changes: 32 additions & 8 deletions src/algorithm/hgraph/hgraph_serialize.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -12,18 +12,42 @@
// See the License for the specific language governing permissions and
// limitations under the License.

#include <fmt/format.h>

#include "datacell/sparse_graph_datacell.h"
#include <fmt/core.h>

#include <atomic>
#include <cstdint>
#include <limits>
#include <memory>
#include <string>
#include <vector>

#include "algorithm/hgraph/hgraph_parameter.h"
#include "algorithm/inner_index_interface.h"
#include "algorithm/inner_index_parameter.h"
#include "basic_types.h"
#include "container_types.h"
#include "data_type.h"
#include "datacell/attribute_inverted_interface.h"
#include "datacell/extra_info_interface.h"
#include "datacell/flatten_interface.h"
#include "datacell/graph_interface.h"
#include "hgraph.h" // IWYU pragma: keep
#include "impl/heap/standard_heap.h"
#include "impl/odescent/odescent_graph_builder.h"
#include "impl/pruning_strategy.h"
#include "impl/label_table/label_table.h"
#include "impl/logger/logger.h"
#include "inner_string_params.h"
#include "json_types.h"
#include "json_wrapper.h"
#include "metric_type.h"
#include "storage/serialization.h"
#include "storage/stream_reader.h"
#include "typing.h"
#include "storage/stream_writer.h"
#include "tsl/robin_map.h"
#include "utils/lock_strategy.h"
#include "utils/util_functions.h"
#include "vsag/options.h"
#include "utils/visited_list.h"
#include "vsag/constants.h"
#include "vsag/errors.h"
#include "vsag_exception.h"

namespace vsag {

Expand Down
11 changes: 11 additions & 0 deletions src/algorithm/hnswlib/block_manager.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,17 @@

#include "block_manager.h"

#include <algorithm>
#include <cstdint>
#include <ios>
#include <new>
#include <stdexcept>
#include <string>

#include "storage/stream_reader.h"
#include "storage/stream_writer.h"
#include "vsag/allocator.h"

namespace hnswlib {

BlockManager::BlockManager(uint64_t size_data_per_element,
Expand Down
Loading
Loading