[skip ci] Add comment for filterDeleteNode Operate (#12565)

Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
pull/12579/head
bigsheeper 2021-12-01 22:30:06 +08:00 committed by GitHub
parent 3d4084be48
commit 87251ce295
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 0 deletions

View File

@ -39,6 +39,7 @@ func (fddNode *filterDeleteNode) Name() string {
return "fdNode"
}
// Operate handles input messages, to filter invalid delete messages
func (fddNode *filterDeleteNode) Operate(in []flowgraph.Msg) []flowgraph.Msg {
if len(in) != 1 {
log.Error("Invalid operate message input in filterDDNode", zap.Int("input length", len(in)))