admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2025-12-08 01:58:34 +08:00
Code Issues Packages Projects Releases Wiki Activity

Add comment and implementation assertion for ddnode (#9333)

Browse Source 
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
This commit is contained in:
congqixia 2021-10-07 19:54:56 +08:00 committed by GitHub
parent 98c26b56a6
commit 908b7df41d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/datanode/flow_graph_dd_node.go
View File

@ -21,10 +21,14 @@ import (
"github.com/milvus-io/milvus/internal/proto/commonpb" "github.com/milvus-io/milvus/internal/proto/commonpb"
"github.com/milvus-io/milvus/internal/proto/datapb" "github.com/milvus-io/milvus/internal/proto/datapb"
"github.com/milvus-io/milvus/internal/proto/internalpb" "github.com/milvus-io/milvus/internal/proto/internalpb"
"github.com/milvus-io/milvus/internal/util/flowgraph"
"github.com/milvus-io/milvus/internal/util/trace" "github.com/milvus-io/milvus/internal/util/trace"
"github.com/opentracing/opentracing-go" "github.com/opentracing/opentracing-go"
) )
// make sure ddNode implements flowgraph.Node
var _ flowgraph.Node = (*ddNode)(nil)
// ddNode filter messages from message streams. // ddNode filter messages from message streams.
// //
// ddNode recives all the messages from message stream dml channels, including insert messages, // ddNode recives all the messages from message stream dml channels, including insert messages,
@ -49,10 +53,12 @@ type ddNode struct {
flushedSegments []UniqueID flushedSegments []UniqueID
} }
// Name returns node name, implementing flowgraph.Node
func (ddn *ddNode) Name() string { func (ddn *ddNode) Name() string {
return "ddNode" return "ddNode"
} }
// Operate handles input messages, implementing flowgrpah.Node
func (ddn *ddNode) Operate(in []Msg) []Msg { func (ddn *ddNode) Operate(in []Msg) []Msg {
// log.Debug("DDNode Operating") // log.Debug("DDNode Operating")