compiler

Documentation

Index

• Variables
• 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 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 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 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