From 0c64666a37c8c5ca1103030b79b6f12955061ad6 Mon Sep 17 00:00:00 2001 From: Likith B Date: Fri, 7 Feb 2025 15:29:01 +0530 Subject: [PATCH] MB-57888: Naming changes --- merge.go | 4 ++-- section_inverted_text_index.go | 15 +++++++-------- 2 files changed, 9 insertions(+), 10 deletions(-) diff --git a/merge.go b/merge.go index c7bfdf3..c7c6a15 100644 --- a/merge.go +++ b/merge.go @@ -114,7 +114,7 @@ func filterFields(fieldsInv []string, fieldInfo map[string]*index.UpdateFieldInf rv := make([]string, 0) for _, field := range fieldsInv { if val, ok := fieldInfo[field]; ok { - if val.RemoveAll { + if val.Deleted { continue } } @@ -636,7 +636,7 @@ func mergeUpdatedFields(segments []*SegmentBase) map[string]*index.UpdateFieldIn if _, ok := fieldInfo[field]; !ok { fieldInfo[field] = info } else { - fieldInfo[field].RemoveAll = fieldInfo[field].RemoveAll || info.RemoveAll + fieldInfo[field].Deleted = fieldInfo[field].Deleted || info.Deleted fieldInfo[field].Index = fieldInfo[field].Index || info.Index fieldInfo[field].Store = fieldInfo[field].Store || info.Store fieldInfo[field].DocValues = fieldInfo[field].Store || info.DocValues diff --git a/section_inverted_text_index.go b/section_inverted_text_index.go index d4eeafa..872cac1 100644 --- a/section_inverted_text_index.go +++ b/section_inverted_text_index.go @@ -127,16 +127,15 @@ func mergeAndPersistInvertedSection(segments []*SegmentBase, dropsIn []*roaring. return nil, 0, seg.ErrClosed } - var dict *Dictionary - var err2 error if info, ok := updatedFields[fieldName]; ok && info.Index { - dict = nil - } else { - dict, err2 = segment.dictionary(fieldName) - if err2 != nil { - return nil, 0, err2 - } + continue } + + dict, err2 := segment.dictionary(fieldName) + if err2 != nil { + return nil, 0, err2 + } + if dict != nil && dict.fst != nil { itr, err2 := dict.fst.Iterator(nil, nil) if err2 != nil && err2 != vellum.ErrIteratorDone {