kernel

Documentation

Index

• Variables
• func CompileAssignment(zctx *zed.Context, node *dag.Assignment) (expr.Assignment, error)
• func CompileAssignments(zctx *zed.Context, dsts field.List, srcs field.List) (field.List, []expr.Evaluator)
• func CompileBufferFilter(zctx *zed.Context, e dag.Expr) (*expr.BufferFilter, error)
• func CompileExprs(zctx *zed.Context, nodes []dag.Expr) ([]expr.Evaluator, error)
• func EvalAtCompileTime(zctx *zed.Context, in dag.Expr) (val *zed.Value, err error)
• type Builder
  • func NewBuilder(pctx *op.Context, adaptor op.DataAdaptor) *Builder
  • func (b *Builder) Build(seq *dag.Sequential) ([]zbuf.Puller, error)
  • func (b *Builder) Meters() []zbuf.Meter
  • func (b *Builder) PushdownOf(trunk *dag.Trunk) (*Filter, error)
• type Filter
  • func (f *Filter) AsBufferFilter() (*expr.BufferFilter, error)
  • func (f *Filter) AsEvaluator() (expr.Evaluator, error)
• type Reader
  • func (*Reader) Source()

Variables

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

Functions

func CompileAssignment

func CompileAssignment(zctx *zed.Context, node *dag.Assignment) (expr.Assignment, error)

func CompileAssignments

func CompileAssignments(zctx *zed.Context, dsts field.List, srcs field.List) (field.List, []expr.Evaluator)

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 CompileExprs

func CompileExprs(zctx *zed.Context, nodes []dag.Expr) ([]expr.Evaluator, error)

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(pctx *op.Context, adaptor op.DataAdaptor) *Builder

func (*Builder) Build

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

func (*Builder) Meters

func (b *Builder) Meters() []zbuf.Meter

func (*Builder) PushdownOf

func (b *Builder) PushdownOf(trunk *dag.Trunk) (*Filter, 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 {
	Layout  order.Layout
	Readers []zio.Reader
}

func (*Reader) Source

func (*Reader) Source()