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

Function Copy

vector/vio/io.go:87–97  ·  view source on GitHub ↗
(dst Pusher, src Puller)

Source from the content-addressed store, hash-verified

85}
86
87func Copy(dst Pusher, src Puller) error {
88 for {
89 vec, err := src.Pull(false)
90 if err != nil || vec == nil {
91 return err
92 }
93 if err := dst.Push(vec); err != nil {
94 return err
95 }
96 }
97}
98
99func CopyMux(outputs map[string]Pusher, parent Puller) error {
100 for {

Callers 15

runOneBoomerangFunction · 0.92
runFunction · 0.92
RunMethod · 0.92
RunMethod · 0.92
RunMethod · 0.92
RunMethod · 0.92
RunMethod · 0.92
RunMethod · 0.92
writeValueMethod · 0.92
RunMethod · 0.92
RunMethod · 0.92
listMethod · 0.92

Calls 2

PullMethod · 0.65
PushMethod · 0.65

Tested by 3

runOneBoomerangFunction · 0.74
TestDirS3SourceFunction · 0.74