Skip to content

Commit 52f3de4

Browse files
added filter for vector lengths
1 parent 1f2476c commit 52f3de4

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

posting/index.go

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -457,14 +457,14 @@ func (txn *Txn) addConflictKeyWithUid(key []byte, pl *pb.PostingList, hasUpsert
457457
if txn.conflicts == nil {
458458
txn.conflicts = make(map[uint64]struct{})
459459
}
460-
keyHash := farm.Fingerprint64(key)
461-
// if hasUpsert {
462-
// txn.conflicts[keyHash] = struct{}{}
463-
// return
460+
// keyHash := farm.Fingerprint64(key)
461+
// // if hasUpsert {
462+
// // txn.conflicts[keyHash] = struct{}{}
463+
// // return
464+
// // }
465+
// for _, post := range pl.Postings {
466+
// txn.conflicts[keyHash^post.Uid] = struct{}{}
464467
// }
465-
for _, post := range pl.Postings {
466-
txn.conflicts[keyHash^post.Uid] = struct{}{}
467-
}
468468
}
469469

470470
func (mp *MutationPipeline) ProcessCount(ctx context.Context, pipeline *PredicatePipeline, postings *map[uint64]*pb.PostingList, info predicateInfo) error {

0 commit comments

Comments
 (0)