shape

Documentation

Index

• Variables
• type Proc
  • func New(pctx *op.Context, parent zbuf.Puller) (*Proc, error)
  • func (p *Proc) Pull(done bool) (zbuf.Batch, error)
• type Shaper
  • 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

Variables

var BatchSize = 100

var MemMaxBytes = 128 * 1024 * 1024

Types

type Proc

type Proc struct {
	// contains filtered or unexported fields
}

func New

func New(pctx *op.Context, parent zbuf.Puller) (*Proc, error)

func (*Proc) Pull

func (p *Proc) Pull(done bool) (zbuf.Batch, error)

type Shaper

type Shaper struct {
	// contains filtered or unexported fields
}

func NewShaper

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

func (*Shaper) Close

func (s *Shaper) Close() error

Close removes the receiver's temporary file if it created one.

func (*Shaper) Read

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

func (*Shaper) Write

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

Write buffers rec. If called after Read, Write panics.