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
- type Job
Constants ¶
This section is empty.
Variables ¶
View Source
var Parallelism = runtime.GOMAXPROCS(0) //XXX
Functions ¶
func CompileWithSortKey ¶ added in v1.8.0
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 NewCompiler ¶ added in v1.2.0
func NewFileSystemCompiler ¶ added in v1.2.0
func NewLakeCompiler ¶ added in v1.2.0
func NewLakeCompiler(r *lake.Root) zedruntime.Compiler
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 (*Job) Optimize ¶ added in v1.2.0
This must be called before the zbuf.Filter interface will work.
func (*Job) OptimizeDeleter ¶ added in v1.8.0
func (*Job) Parallelize ¶ added in v1.2.0
Click to show internal directories.
Click to hide internal directories.