compiler

Documentation

Index

• Variables
• func MustParseOp(query string) ast.Op
• func ParseOp(src string, filenames ...string) (ast.Op, error)
• func ParseRangeExpr(zctx *zed.Context, src string, layout order.Layout) (*zed.Value, string, error)
• type Runtime
  • func CompileForFileSystem(pctx *op.Context, o ast.Op, readers []zio.Reader, adaptor op.DataAdaptor) (*Runtime, error)
  • func CompileForInternal(pctx *op.Context, o ast.Op, r zio.Reader) (*Runtime, error)
  • func CompileForInternalWithOrder(pctx *op.Context, o ast.Op, r zio.Reader, layout order.Layout) (*Runtime, error)
  • func CompileForLake(pctx *op.Context, program ast.Op, lake op.DataAdaptor, parallelism int, ...) (*Runtime, error)
  • func New(pctx *op.Context, inAST ast.Op, 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 MustParseOp

func MustParseOp(query string) ast.Op

MustParseOp is like ParseOp but panics if an error is encountered.

func ParseOp

func ParseOp(src string, filenames ...string) (ast.Op, error)

ParseOp concatenates the source files in filenames followed by src and parses the resulting program.

func ParseRangeExpr

func ParseRangeExpr(zctx *zed.Context, src string, layout order.Layout) (*zed.Value, string, error)

Types

type Runtime

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

func CompileForFileSystem

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

func CompileForInternal

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

func CompileForInternalWithOrder

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

func CompileForLake

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

func New

func New(pctx *op.Context, inAST ast.Op, 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