added filter for vector lengths

Author: darkcoderrises

posting/index.go

@@ -656,6 +656,7 @@ func (mp *MutationPipeline) ProcessSingle(ctx context.Context, pipeline *Predica
 
 	var oldVal *pb.Posting
 	for edge := range pipeline.edges {
+		//fmt.Println("EDGE", edge)
 		if edge.Op != pb.DirectedEdge_DEL && !schemaExists {
 			return errors.Errorf("runMutation: Unable to find schema for %s", edge.Attr)
 		}

posting/lists.go

@@ -441,15 +441,13 @@ func (lc *LocalCache) GetSinglePosting(key []byte) (*pb.PostingList, error) {
 		return lc.readPostingListAt(key)
 	}
 
-	pk, _ := x.Parse(key)
-
 	pl, err := getPostings()
 	if err == badger.ErrKeyNotFound {
-		fmt.Println("READING ", pk, nil)
+		//fmt.Println("READING ", pk, nil)
 		return nil, nil
 	}
 	if err != nil {
-		fmt.Println("READING ", pk, err)
+		//fmt.Println("READING ", pk, err)
 		return nil, err
 	}
 
@@ -462,7 +460,7 @@ func (lc *LocalCache) GetSinglePosting(key []byte) (*pb.PostingList, error) {
 		}
 	}
 	pl.Postings = pl.Postings[:idx]
-	fmt.Println("READING ", pk, pl)
+	//fmt.Println("READING ", pk, pl)
 	return pl, nil
 }
 

posting/oracle.go

@@ -77,21 +77,22 @@ func SortAndDedupPostings(postings []*pb.Posting) []*pb.Posting {
 	sort.Slice(postings, func(i, j int) bool {
 		return postings[i].Uid < postings[j].Uid
 	})
+	return postings
 
 	// In-place filtering: keep only the last occurrence for each UID
-	n := 0 // write index
-	for i := 0; i < len(postings); {
-		j := i + 1
-		// Skip all postings with same UID
-		for j < len(postings) && postings[j].Uid == postings[i].Uid {
-			j++
-		}
-		// Keep only the last posting for this UID
-		postings[n] = postings[j-1]
-		n++
-		i = j
-	}
-	return postings[:n]
+	// n := 0 // write index
+	// for i := 0; i < len(postings); {
+	// 	j := i + 1
+	// 	// Skip all postings with same UID
+	// 	for j < len(postings) && postings[j].Uid == postings[i].Uid {
+	// 		j++
+	// 	}
+	// 	// Keep only the last posting for this UID
+	// 	postings[n] = postings[j-1]
+	// 	n++
+	// 	i = j
+	// }
+	// return postings[:n]
 }
 
 func (txn *Txn) AddDelta(key string, pl pb.PostingList) (*pb.PostingList, error) {