From a34b1a3e08118f1808cd0b8af20b8d008c232b79 Mon Sep 17 00:00:00 2001 From: bigsheeper Date: Fri, 3 Dec 2021 20:35:44 +0800 Subject: [PATCH] [skip ci] Add comment for filterDmNode Operate (#12732) Signed-off-by: bigsheeper --- internal/querynode/flow_graph_filter_dm_node.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/querynode/flow_graph_filter_dm_node.go b/internal/querynode/flow_graph_filter_dm_node.go index 3a848052c0..f353724332 100644 --- a/internal/querynode/flow_graph_filter_dm_node.go +++ b/internal/querynode/flow_graph_filter_dm_node.go @@ -43,6 +43,7 @@ func (fdmNode *filterDmNode) Name() string { return "fdmNode" } +// Operate handles input messages, to filter invalid insert messages func (fdmNode *filterDmNode) Operate(in []flowgraph.Msg) []flowgraph.Msg { //log.Debug("Do filterDmNode operation")