compiler

Documentation

Index

• Variables
• func CompileAssignments(zctx *zed.Context, dsts field.List, srcs field.List) (field.List, []expr.Evaluator)
• func MustParseProc(query string) ast.Proc
• func ParseExpression(expr string) (ast.Expr, error)
• func ParseProc(src string, filenames ...string) (ast.Proc, error)
• type Runtime
  • func CompileForFileSystem(pctx *op.Context, p ast.Proc, readers []zio.Reader, adaptor op.DataAdaptor) (*Runtime, error)
  • func CompileForInternal(pctx *op.Context, p ast.Proc, r zio.Reader) (*Runtime, error)
  • func CompileForInternalWithOrder(pctx *op.Context, p ast.Proc, r zio.Reader, layout order.Layout) (*Runtime, error)
  • func CompileForLake(pctx *op.Context, program ast.Proc, lake op.DataAdaptor, parallelism int, ...) (*Runtime, error)
  • func New(pctx *op.Context, inAST ast.Proc, adaptor op.DataAdaptor, ...) (*Runtime, error)
  • func (r *Runtime) Build() error
  • func (r *Runtime) Builder() *kernel.Builder
  • func (r *Runtime) Context() *op.Context
  • func (r *Runtime) Entry() dag.Op
  • func (r *Runtime) Meter() zbuf.Meter
  • func (r *Runtime) Optimize() error
  • func (r *Runtime) Outputs() []zbuf.Puller
  • func (r *Runtime) Parallelize(n int) error
  • func (r *Runtime) Puller() zbuf.Puller

Variables

var Parallelism = runtime.GOMAXPROCS(0) //XXX

Functions

func CompileAssignments

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

func MustParseProc

func MustParseProc(query string) ast.Proc

MustParseProc is functionally the same as ParseProc but panics if an error is encountered.

func ParseExpression

func ParseExpression(expr string) (ast.Expr, error)

func ParseProc

func ParseProc(src string, filenames ...string) (ast.Proc, error)

ParseProc() is an entry point for use from external go code, mostly just a wrapper around Parse() that casts the return value.

Types

type Runtime

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

func CompileForFileSystem

func CompileForFileSystem(pctx *op.Context, p ast.Proc, readers []zio.Reader, adaptor op.DataAdaptor) (*Runtime, error)

func CompileForInternal

func CompileForInternal(pctx *op.Context, p ast.Proc, r zio.Reader) (*Runtime, error)

func CompileForInternalWithOrder

func CompileForInternalWithOrder(pctx *op.Context, p ast.Proc, r zio.Reader, layout order.Layout) (*Runtime, error)

func CompileForLake

func CompileForLake(pctx *op.Context, program ast.Proc, lake op.DataAdaptor, parallelism int, head *lakeparse.Commitish) (*Runtime, error)

func New

func New(pctx *op.Context, inAST ast.Proc, adaptor op.DataAdaptor, head *lakeparse.Commitish) (*Runtime, error)

func (*Runtime) Build

func (r *Runtime) Build() error

func (*Runtime) Builder

func (r *Runtime) Builder() *kernel.Builder

func (*Runtime) Context

func (r *Runtime) Context() *op.Context

func (*Runtime) Entry

func (r *Runtime) Entry() dag.Op

func (*Runtime) Meter

func (r *Runtime) Meter() zbuf.Meter

func (*Runtime) Optimize

func (r *Runtime) Optimize() error

This must be called before the zbuf.Filter interface will work.

func (*Runtime) Outputs

func (r *Runtime) Outputs() []zbuf.Puller

func (*Runtime) Parallelize

func (r *Runtime) Parallelize(n int) error

func (*Runtime) Puller

func (r *Runtime) Puller() zbuf.Puller