shape

Documentation

Index

• Variables
• type Op
  • func New(rctx *runtime.Context, parent zbuf.Puller) (*Op, error)
  • func (o *Op) 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 MemMaxBytes = 128 * 1024 * 1024

Types

type Op

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

func New

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

func (*Op) Pull

func (o *Op) 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.