compiler

Documentation

Index

• Variables
• func CompileWithSortKey(octx *op.Context, seq ast.Seq, r zio.Reader, sortKey order.SortKey) (*runtime.Query, error)
• func MustParse(query string) ast.Seq
• 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.Seq, error)
• type InvalidDeleteWhereQuery
  • func (InvalidDeleteWhereQuery) Error() string
• type Job
  • func NewJob(octx *op.Context, in ast.Seq, src *data.Source, head *lakeparse.Commitish) (*Job, error)
  • func (j *Job) Build() error
  • func (j *Job) Builder() *kernel.Builder
  • func (j *Job) Entry() dag.Seq
  • func (j *Job) Optimize() error
  • func (j *Job) OptimizeDeleter(replicas int) error
  • func (j *Job) Parallelize(n int) error
  • func (j *Job) Puller() zbuf.Puller

Variables

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

Functions

func CompileWithSortKey

func CompileWithSortKey(octx *op.Context, seq ast.Seq, r zio.Reader, sortKey order.SortKey) (*runtime.Query, error)

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

func MustParse

func MustParse(query string) ast.Seq

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.Seq, 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(octx *op.Context, in ast.Seq, 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.Seq

func (*Job) Optimize

func (j *Job) Optimize() error

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

func (*Job) OptimizeDeleter

func (j *Job) OptimizeDeleter(replicas int) error

func (*Job) Parallelize

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

func (*Job) Puller

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