shape

Jan 29, 2024

Changes in this version

+ var MemMaxBytes = 128 * 1024 * 1024

+ type Op struct

+ func New(rctx *runtime.Context, parent zbuf.Puller) (*Op, error)

+ func (o *Op) Pull(done bool) (zbuf.Batch, error)

+ type Shaper struct

+ func NewShaper(zctx *zed.Context, memMaxBytes int) *Shaper

+ func (s *Shaper) Close() error

+ func (s *Shaper) Read() (*zed.Value, error)

+ func (s *Shaper) Write(rec zed.Value) error