compiler

Documentation

Index

• Variables
• func CompileWithSortKey(rctx *runtime.Context, seq ast.Seq, r zio.Reader, sortKey order.SortKey) (*exec.Query, error)
• func MustParse(query string) ast.Seq
• func NewCompiler() runtime.Compiler
• func NewFileSystemCompiler(engine storage.Engine) runtime.Compiler
• func NewLakeCompiler(r *lake.Root) runtime.Compiler
• func Parse(src string, filenames ...string) (ast.Seq, error)
• func VectorCompile(rctx *runtime.Context, query string, object *vcache.Object) (zbuf.Puller, error)
• func VectorFilterCompile(rctx *runtime.Context, query string, src *data.Source, ...) (zbuf.Puller, error)
• type InvalidDeleteWhereQuery
  • func (InvalidDeleteWhereQuery) Error() string
• type Job
  • func NewJob(rctx *runtime.Context, in ast.Seq, src *data.Source, head *lakeparse.Commitish) (*Job, error)
  • func (j *Job) Build(readers ...zio.Reader) error
  • func (j *Job) Builder() *kernel.Builder
  • func (j *Job) DefaultScan() (*dag.DefaultScan, bool)
  • 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 = goruntime.GOMAXPROCS(0) //XXX

Functions

func CompileWithSortKey

func CompileWithSortKey(rctx *runtime.Context, seq ast.Seq, r zio.Reader, sortKey order.SortKey) (*exec.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) runtime.Compiler

func Parse

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

func VectorCompile

func VectorCompile(rctx *runtime.Context, query string, object *vcache.Object) (zbuf.Puller, error)

VectorCompile is used for testing queries over single VNG object scans where the entire query is vectorizable. It does not call optimize nor does it compute the demand of the query to prune the projection from the vcache.

func VectorFilterCompile

func VectorFilterCompile(rctx *runtime.Context, query string, src *data.Source, head *lakeparse.Commitish) (zbuf.Puller, 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(rctx *runtime.Context, in ast.Seq, src *data.Source, head *lakeparse.Commitish) (*Job, error)

func (*Job) Build

func (j *Job) Build(readers ...zio.Reader) error

Build builds a flowgraph for j. If the flowgraph expects an input stream from the runtime (because its DAG contains a dag.DefaultSource), Build constructs it from readers.

func (*Job) Builder

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

func (*Job) DefaultScan

func (j *Job) DefaultScan() (*dag.DefaultScan, bool)

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