MCPcopy Create free account
hub / github.com/brimdata/super / Walk

Function Walk

compiler/optimizer/optimizer.go:76–90  ·  view source on GitHub ↗
(seq dag.Seq, post func(dag.Seq) dag.Seq)

Source from the content-addressed store, hash-verified

74}
75
76func Walk(seq dag.Seq, post func(dag.Seq) dag.Seq) dag.Seq {
77 for _, op := range seq {
78 switch op := op.(type) {
79 case *dag.ForkOp:
80 for k := range op.Paths {
81 op.Paths[k] = Walk(op.Paths[k], post)
82 }
83 case *dag.ScatterOp:
84 for k := range op.Paths {
85 op.Paths[k] = Walk(op.Paths[k], post)
86 }
87 }
88 }
89 return post(seq)
90}
91
92func walkEntries(seq dag.Seq, post func(dag.Seq) (dag.Seq, error)) (dag.Seq, error) {
93 for _, op := range seq {

Callers 4

collectOutputsFunction · 0.92
removePassOpsFunction · 0.70
mergeValuesOpsFunction · 0.70
optimizeParallelsMethod · 0.70

Calls

no outgoing calls

Tested by

no test coverage detected