kernel

Documentation

Index

• Variables
• func CompileBufferFilter(zctx *zed.Context, e dag.Expr) (*expr.BufferFilter, error)
• func EvalAtCompileTime(zctx *zed.Context, in dag.Expr) (val *zed.Value, err error)
• type Builder
  • func NewBuilder(octx *op.Context, source *data.Source) *Builder
  • func (b *Builder) Build(seq dag.Seq) ([]zbuf.Puller, error)
  • func (b *Builder) Deletes() *sync.Map
  • func (b *Builder) Meter() zbuf.Meter
  • func (b *Builder) PushdownOf(e dag.Expr) *Filter
• type DeleteFilter
  • func (f *DeleteFilter) AsBufferFilter() (*expr.BufferFilter, error)
  • func (f *DeleteFilter) AsEvaluator() (expr.Evaluator, error)
• type Filter
  • func (f *Filter) AsBufferFilter() (*expr.BufferFilter, error)
  • func (f *Filter) AsEvaluator() (expr.Evaluator, error)
• type Reader
  • func (*Reader) OpNode()
  • func (*Reader) Source()

Variables

var ErrJoinParents = errors.New("join requires two upstream parallel query paths")

Functions

func CompileBufferFilter

func CompileBufferFilter(zctx *zed.Context, e dag.Expr) (*expr.BufferFilter, error)

CompileBufferFilter tries to return a BufferFilter for e such that the BufferFilter's Eval method returns true for any byte slice containing the ZNG encoding of a record matching e. (It may also return true for some byte slices that do not match.) compileBufferFilter returns a nil pointer and nil error if it cannot construct a useful filter.

func EvalAtCompileTime

func EvalAtCompileTime(zctx *zed.Context, in dag.Expr) (val *zed.Value, err error)

Types

type Builder

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

func NewBuilder

func NewBuilder(octx *op.Context, source *data.Source) *Builder

func (*Builder) Build

func (b *Builder) Build(seq dag.Seq) ([]zbuf.Puller, error)

func (*Builder) Deletes

func (b *Builder) Deletes() *sync.Map

func (*Builder) Meter

func (b *Builder) Meter() zbuf.Meter

func (*Builder) PushdownOf

func (b *Builder) PushdownOf(e dag.Expr) *Filter

type DeleteFilter

type DeleteFilter struct {
	*Filter
}

func (*DeleteFilter) AsBufferFilter

func (f *DeleteFilter) AsBufferFilter() (*expr.BufferFilter, error)

func (*DeleteFilter) AsEvaluator

func (f *DeleteFilter) AsEvaluator() (expr.Evaluator, error)

type Filter

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

func (*Filter) AsBufferFilter

func (f *Filter) AsBufferFilter() (*expr.BufferFilter, error)

func (*Filter) AsEvaluator

func (f *Filter) AsEvaluator() (expr.Evaluator, error)

type Reader

type Reader struct {
	SortKey order.SortKey
	Filter  dag.Expr
	Readers []zio.Reader
}

func (*Reader) OpNode

func (*Reader) OpNode()

func (*Reader) Source

func (*Reader) Source()