summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorchenzizhan <[email protected]>2024-03-18 18:12:19 +0800
committerchenzizhan <[email protected]>2024-03-18 18:12:19 +0800
commit207720a3be6699a3ecb4241d533df626faec4d5f (patch)
tree23df6575039bd078f99a4253cda05d8059989b69
parent05a08ab6e66b169246c61bbcec0e9b70b65d7744 (diff)
Revert "skip empty heavykeeper"
s This reverts commit 0a5c5a1fc3d4a2913086ec53854a6b340d82830a.
-rw-r--r--src/tags/cell_manager.c9
-rw-r--r--src/tags/heavy_keeper.c3
2 files changed, 0 insertions, 12 deletions
diff --git a/src/tags/cell_manager.c b/src/tags/cell_manager.c
index 410ca58..d5f86c0 100644
--- a/src/tags/cell_manager.c
+++ b/src/tags/cell_manager.c
@@ -310,15 +310,6 @@ int cell_manager_find(const struct cell_manager *pthis, const struct tag_hash_ke
void cell_manager_merge_topk(struct cell_manager *dest, const struct cell_manager *src,
int **cell_id_popped, int *n_cell_id_popped, int **cell_id_old, int **cell_id_added, int *n_cell_id_added)
{
- // empty src: return directly
- if (heavy_keeper_get_cardinality(src->topk_tag_id_map) == 0) {
- *n_cell_id_popped = 0;
- *n_cell_id_added = 0;
- *cell_id_popped = NULL;
- *cell_id_old = NULL;
- *cell_id_added = NULL;
- return;
- }
heavy_keeper_merge_recording_id_details(dest->topk_tag_id_map, src->topk_tag_id_map,
cell_id_popped, n_cell_id_popped, cell_id_old, cell_id_added, n_cell_id_added);
diff --git a/src/tags/heavy_keeper.c b/src/tags/heavy_keeper.c
index 24b33fc..894eead 100644
--- a/src/tags/heavy_keeper.c
+++ b/src/tags/heavy_keeper.c
@@ -101,9 +101,6 @@ struct heavy_keeper *heavy_keeper_with_data_new(int max_query_num) {
}
void heavy_keeper_reset(struct heavy_keeper *hk) {
- if (heavy_keeper_get_cardinality(hk) == 0) {
- return;
- }
memset(hk->sketch, 0, (size_t)hk->params.array_num * (size_t)hk->params.max_bucket_num * sizeof(struct Bucket));
sorted_set_reset(hk->top_K_heap);
}