milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

enhance: Remove deprecated EnableIndex (#32704) 

/kind improvement

Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
pull/32819/head
yihao.dai 2024-05-07 17:11:30 +08:00 committed by GitHub
parent 641f702f64
commit 9db3aa18bc
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
4 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/querycoordv2/meta/coordinator_broker.go
View File

@ -229,7 +229,7 @@ func (broker *CoordinatorBroker) GetIndexInfo(ctx context.Context, collectionID
for _, info := range segmentInfo.GetIndexInfos() {
indexes = append(indexes, &querypb.FieldIndexInfo{
FieldID: info.GetFieldID(),
EnableIndex: true,
EnableIndex: true, // deprecated, but keep it for compatibility
IndexName: info.GetIndexName(),
IndexID: info.GetIndexID(),
BuildID: info.GetBuildID(),

2
internal/querynodev2/segments/mock_data.go
View File

@ -1075,7 +1075,6 @@ func GenAndSaveIndexV2(collectionID, partitionID, segmentID, buildID int64,
return &querypb.FieldIndexInfo{
FieldID: fieldSchema.GetFieldID(),
EnableIndex: true,
IndexName: indexInfo.GetIndexName(),
IndexParams: indexInfo.GetIndexParams(),
IndexFilePaths: indexPaths,
@ -1136,7 +1135,6 @@ func GenAndSaveIndex(collectionID, partitionID, segmentID, fieldID int64, msgLen
return &querypb.FieldIndexInfo{
FieldID: fieldID,
EnableIndex: true,
IndexName: "querynode-test",
IndexParams: funcutil.Map2KeyValuePair(indexParams),
IndexFilePaths: indexPaths,

2
internal/querynodev2/segments/segment.go
View File

@ -499,7 +499,7 @@ func (s *LocalSegment) ExistIndex(fieldID int64) bool {
if !ok {
return false
}
return fieldInfo.IndexInfo != nil && fieldInfo.IndexInfo.EnableIndex
return fieldInfo.IndexInfo != nil
}
func (s *LocalSegment) HasRawData(fieldID int64) bool {

6
internal/querynodev2/segments/segment_loader.go
View File

@ -1556,10 +1556,8 @@ func getResourceUsageEstimateOfSegment(schema *schemapb.CollectionSchema, loadIn
vecFieldID2IndexInfo := make(map[int64]*querypb.FieldIndexInfo)
for _, fieldIndexInfo := range loadInfo.IndexInfos {
if fieldIndexInfo.EnableIndex {
fieldID := fieldIndexInfo.FieldID
vecFieldID2IndexInfo[fieldID] = fieldIndexInfo
}
fieldID := fieldIndexInfo.FieldID
vecFieldID2IndexInfo[fieldID] = fieldIndexInfo
}
for _, fieldBinlog := range loadInfo.BinlogPaths {