compiler

Documentation

Index

• Variables
• func CompileAssignments(dsts field.List, srcs field.List) (field.List, []expr.Evaluator)
• func MustParseProc(query string) ast.Proc
• func ParseExpression(expr string) (ast.Expr, error)
• func ParseProc(src string, filenames ...string) (ast.Proc, error)
• type Runtime
  • func CompileForFileSystem(pctx *proc.Context, p ast.Proc, reader zio.Reader, adaptor proc.DataAdaptor) (*Runtime, error)
  • func CompileForInternal(pctx *proc.Context, p ast.Proc, r zio.Reader) (*Runtime, error)
  • func CompileForInternalWithOrder(pctx *proc.Context, p ast.Proc, r zio.Reader, layout order.Layout) (*Runtime, error)
  • func CompileForLake(pctx *proc.Context, program ast.Proc, lake proc.DataAdaptor, parallelism int, ...) (*Runtime, error)
  • func CompileJoinForFileSystem(pctx *proc.Context, p ast.Proc, readers []zio.Reader, adaptor proc.DataAdaptor) (*Runtime, error)
  • func New(pctx *proc.Context, inAST ast.Proc, adaptor proc.DataAdaptor, ...) (*Runtime, error)
  • func (r *Runtime) Build() error
  • func (r *Runtime) Builder() *kernel.Builder
  • func (r *Runtime) Context() *proc.Context
  • func (r *Runtime) Entry() dag.Op
  • func (r *Runtime) Optimize() error
  • func (r *Runtime) Outputs() []proc.Interface
  • func (r *Runtime) Parallelize(n int) error
  • func (r *Runtime) Puller() zbuf.Puller
  • func (r *Runtime) Statser() zbuf.Statser

Variables

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

Functions

func CompileAssignments

func CompileAssignments(dsts field.List, srcs field.List) (field.List, []expr.Evaluator)

func MustParseProc

func MustParseProc(query string) ast.Proc

MustParseProc is functionally the same as ParseProc but panics if an error is encountered.

func ParseExpression

func ParseExpression(expr string) (ast.Expr, error)

func ParseProc

func ParseProc(src string, filenames ...string) (ast.Proc, error)

ParseProc() is an entry point for use from external go code, mostly just a wrapper around Parse() that casts the return value.

Types

type Runtime

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

func CompileForFileSystem

func CompileForFileSystem(pctx *proc.Context, p ast.Proc, reader zio.Reader, adaptor proc.DataAdaptor) (*Runtime, error)

func CompileForInternal

func CompileForInternal(pctx *proc.Context, p ast.Proc, r zio.Reader) (*Runtime, error)

func CompileForInternalWithOrder

func CompileForInternalWithOrder(pctx *proc.Context, p ast.Proc, r zio.Reader, layout order.Layout) (*Runtime, error)

func CompileForLake

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

func CompileJoinForFileSystem

func CompileJoinForFileSystem(pctx *proc.Context, p ast.Proc, readers []zio.Reader, adaptor proc.DataAdaptor) (*Runtime, error)

func New

func New(pctx *proc.Context, inAST ast.Proc, adaptor proc.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() *proc.Context

func (*Runtime) Entry

func (r *Runtime) Entry() dag.Op

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() []proc.Interface

func (*Runtime) Parallelize

func (r *Runtime) Parallelize(n int) error

func (*Runtime) Puller

func (r *Runtime) Puller() zbuf.Puller

func (*Runtime) Statser

func (r *Runtime) Statser() zbuf.Statser