fuse

Documentation

Index

• Variables
• type Fuser
  • func NewFuser(zctx *zed.Context, memMaxBytes int) *Fuser
  • func (f *Fuser) Close() error
  • func (f *Fuser) Read() (*zed.Value, error)
  • func (f *Fuser) Write(rec zed.Value) error
• type Op
  • func New(rctx *runtime.Context, parent zbuf.Puller) (*Op, error)
  • func (o *Op) Pull(done bool) (zbuf.Batch, error)

Variables

var MemMaxBytes = 128 * 1024 * 1024

Types

type Fuser

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

Fuser buffers records written to it, assembling from them a unified schema of fields and types. Fuser then transforms those records to the unified schema as they are read back from it.

func NewFuser

func NewFuser(zctx *zed.Context, memMaxBytes int) *Fuser

NewFuser returns a new Fuser. The Fuser buffers records in memory until their cumulative size (measured in zcode.Bytes length) exceeds memMaxBytes, at which point it buffers them in a temporary file.

func (*Fuser) Close

func (f *Fuser) Close() error

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

func (*Fuser) Read

func (f *Fuser) Read() (*zed.Value, error)

Read returns the next buffered record after transforming it to the unified schema.

func (*Fuser) Write

func (f *Fuser) Write(rec zed.Value) error

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

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)