shape

package
v1.15.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 29, 2024 License: BSD-3-Clause Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var MemMaxBytes = 128 * 1024 * 1024

Functions

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL