From b206980febebe4c996d60df7fed7ea4c6ec7a833 Mon Sep 17 00:00:00 2001 From: bigsheeper Date: Thu, 9 Dec 2021 14:12:00 +0800 Subject: [PATCH] [skip ci] Add comment for filterSegmentsByPKs (#13036) Signed-off-by: bigsheeper --- internal/querynode/flow_graph_insert_node.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/querynode/flow_graph_insert_node.go b/internal/querynode/flow_graph_insert_node.go index b2528c5cb4..d95046f7a8 100644 --- a/internal/querynode/flow_graph_insert_node.go +++ b/internal/querynode/flow_graph_insert_node.go @@ -244,6 +244,7 @@ func processDeleteMessages(replica ReplicaInterface, msg *msgstream.DeleteMsg, d } } +// filterSegmentsByPKs would filter segments by primary keys func filterSegmentsByPKs(pks []int64, segment *Segment) ([]int64, error) { if pks == nil { return nil, fmt.Errorf("pks is nil when getSegmentsByPKs")