compiler

package

v1.13.0 Latest Latest Go to latest Published: Jan 29, 2024 License: BSD-3-Clause Imports: 19 Imported by: 5

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/brimdata/zed

Links

Open Source Insights

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)
type InvalidDeleteWhereQuery
- func (InvalidDeleteWhereQuery) Error() string
type Job
- func NewJob(rctx *runtime.Context, in ast.Seq, src *data.Source, head *lakeparse.Commitish) (*Job, error)

Constants ¶

This section is empty.

Variables ¶

View Source

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

Functions ¶

func CompileWithSortKey ¶ added in v1.8.0

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 ¶ added in v1.2.0

func MustParse(query string) ast.Seq

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

func NewCompiler ¶ added in v1.2.0

func NewCompiler() runtime.Compiler

func NewFileSystemCompiler ¶ added in v1.2.0

func NewFileSystemCompiler(engine storage.Engine) runtime.Compiler

func NewLakeCompiler ¶ added in v1.2.0

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

func Parse ¶ added in v1.2.0

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

Types ¶

type InvalidDeleteWhereQuery ¶ added in v1.3.0

type InvalidDeleteWhereQuery struct{}

func (InvalidDeleteWhereQuery) Error ¶ added in v1.3.0

func (InvalidDeleteWhereQuery) Error() string

type Job ¶ added in v1.2.0

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

func NewJob ¶ added in v1.2.0

func NewJob(rctx *runtime.Context, in ast.Seq, src *data.Source, head *lakeparse.Commitish) (*Job, error)

func (*Job) Build ¶ added in v1.2.0

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 ¶ added in v1.2.0

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

func (*Job) DefaultScan ¶ added in v1.12.0

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

func (*Job) Entry ¶ added in v1.2.0

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

func (*Job) Optimize ¶ added in v1.2.0

func (j *Job) Optimize() error

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

func (*Job) OptimizeDeleter ¶ added in v1.8.0

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

func (*Job) Parallelize ¶ added in v1.2.0

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

func (*Job) Puller ¶ added in v1.2.0

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
ast Package ast declares the types used to represent syntax trees for Zed queries.	Package ast declares the types used to represent syntax trees for Zed queries.
dag
zed
data
kernel
optimizer
demand
parser
semantic

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL