compiler

Documentation

Index

• Variables
• func CompileWithLayout(pctx *op.Context, o ast.Op, r zio.Reader, layout order.Layout) (*runtime.Query, error)
• func MustParse(query string) ast.Op
• func NewCompiler() runtime.Compiler
• func NewFileSystemCompiler(engine storage.Engine) runtime.Compiler
• func NewLakeCompiler(r *lake.Root) zedruntime.Compiler
• func Parse(src string, filenames ...string) (ast.Op, error)
• type InvalidDeleteWhereQuery
  • func (InvalidDeleteWhereQuery) Error() string
• type Job
  • func NewJob(pctx *op.Context, inAST ast.Op, src *data.Source, head *lakeparse.Commitish) (*Job, error)
  • func (j *Job) Build() error
  • func (j *Job) Builder() *kernel.Builder
  • func (j *Job) Entry() dag.Op
  • func (j *Job) Optimize() error
  • func (j *Job) Parallelize(n int) error
  • func (j *Job) Puller() zbuf.Puller

Variables

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

Functions

func CompileWithLayout

func CompileWithLayout(pctx *op.Context, o ast.Op, r zio.Reader, layout order.Layout) (*runtime.Query, error)

XXX currently used only by group-by test, need to deprecate

func MustParse

func MustParse(query string) ast.Op

MustParse is like Parse but panics if an error is encountered.

func NewCompiler

func NewCompiler() runtime.Compiler

func NewFileSystemCompiler

func NewFileSystemCompiler(engine storage.Engine) runtime.Compiler

func NewLakeCompiler

func NewLakeCompiler(r *lake.Root) zedruntime.Compiler

func Parse

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

Types

type InvalidDeleteWhereQuery

type InvalidDeleteWhereQuery struct{}

func (InvalidDeleteWhereQuery) Error

func (InvalidDeleteWhereQuery) Error() string

type Job

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

func NewJob

func NewJob(pctx *op.Context, inAST ast.Op, src *data.Source, head *lakeparse.Commitish) (*Job, error)

func (*Job) Build

func (j *Job) Build() error

func (*Job) Builder

func (j *Job) Builder() *kernel.Builder

func (*Job) Entry

func (j *Job) Entry() dag.Op

func (*Job) Optimize

func (j *Job) Optimize() error

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

func (*Job) Parallelize

func (j *Job) Parallelize(n int) error

func (*Job) Puller

func (j *Job) Puller() zbuf.Puller