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

Function NewPuller

sbuf/batch.go:69–71  ·  view source on GitHub ↗

NewPuller returns a puller for zr that returns batches containing up to [PullerBatchBytes] bytes and [PullerBatchValues] values.

(zr sio.Reader)

Source from the content-addressed store, hash-verified

67// NewPuller returns a puller for zr that returns batches containing up to
68// [PullerBatchBytes] bytes and [PullerBatchValues] values.
69func NewPuller(zr sio.Reader) Puller {
70 return &puller{zr}
71}
72
73type puller struct {
74 zr sio.Reader

Callers 14

runOneBoomerangFunction · 0.92
compileVamLeafMethod · 0.92
compileLeafMethod · 0.92
RunMethod · 0.92
RunMethod · 0.92
RunMethod · 0.92
PullMethod · 0.92
TestParallelOrderFunction · 0.92
sendSpillsMethod · 0.92
pushOutputMethod · 0.92
errOnValMethod · 0.92
CreateVectorFunction · 0.92

Calls

no outgoing calls

Tested by 3

runOneBoomerangFunction · 0.74
TestParallelOrderFunction · 0.74
TestDirS3SourceFunction · 0.74