added filter for vector lengths

Author: darkcoderrises

posting/index.go

@@ -234,12 +234,12 @@ func (mp *MutationPipeline) InsertTokenizerIndexes(ctx context.Context, pipeline
 	mp.txn.cache.Lock()
 	defer mp.txn.cache.Unlock()
 
-	// if info.hasUpsert {
-	// 	globalMapI.Iterate(func(key string, value *pb.PostingList) error {
-	// 		mp.txn.addConflictKey(farm.Fingerprint64([]byte(key)))
-	// 		return nil
-	// 	})
-	// }
+	if info.hasUpsert {
+		globalMapI.Iterate(func(key string, value *pb.PostingList) error {
+			mp.txn.addConflictKey(farm.Fingerprint64([]byte(key)))
+			return nil
+		})
+	}
 
 	globalMap := mp.txn.cache.deltas.GetIndexMapForPredicate(pipeline.attr)
 	if globalMap == nil {
@@ -378,7 +378,9 @@ func (mp *MutationPipeline) ProcessReverse(ctx context.Context, pipeline *Predic
 	}
 
 	if info.count {
-		return mp.ProcessCount(ctx, pipeline, &reverseredMap, info)
+		newInfo := info
+		newInfo.isList = true
+		return mp.ProcessCount(ctx, pipeline, &reverseredMap, newInfo)
 	}
 
 	for uid, pl := range reverseredMap {
@@ -457,14 +459,14 @@ func (txn *Txn) addConflictKeyWithUid(key []byte, pl *pb.PostingList, hasUpsert
 	if txn.conflicts == nil {
 		txn.conflicts = make(map[uint64]struct{})
 	}
-	// keyHash := farm.Fingerprint64(key)
-	// // if hasUpsert {
-	// // 	txn.conflicts[keyHash] = struct{}{}
-	// // 	return
-	// // }
-	// for _, post := range pl.Postings {
-	// 	txn.conflicts[keyHash^post.Uid] = struct{}{}
+	keyHash := farm.Fingerprint64(key)
+	// if hasUpsert {
+	// 	txn.conflicts[keyHash] = struct{}{}
+	// 	return
 	// }
+	for _, post := range pl.Postings {
+		txn.conflicts[keyHash^post.Uid] = struct{}{}
+	}
 }
 
 func (mp *MutationPipeline) ProcessCount(ctx context.Context, pipeline *PredicatePipeline, postings *map[uint64]*pb.PostingList, info predicateInfo) error {