runtime

type Compiler ¶ added in v1.2.0

type Compiler interface {
	NewQuery(*op.Context, ast.Op, []zio.Reader) (*Query, error)
	NewLakeQuery(*op.Context, ast.Op, int, *lakeparse.Commitish) (*Query, error)
	Parse(string, ...string) (ast.Op, error)
	ParseRangeExpr(*zed.Context, string, order.Layout) (*zed.Value, string, error)
	//XXX this is used only by the groupby test.
	CompileWithOrderDeprecated(*op.Context, ast.Op, zio.Reader, order.Layout) (*Query, error)
}

type Query ¶

type Query struct {
	zbuf.Puller
	// contains filtered or unexported fields
}

Query runs a flowgraph as a zbuf.Puller and implements a Close() method that gracefully tears down the flowgraph. Its AsReader() and AsProgressReader() methods provide a convenient means to run a flowgraph as zio.Reader.

func CompileLakeQuery(ctx context.Context, zctx *zed.Context, c Compiler, program ast.Op, head *lakeparse.Commitish, logger *zap.Logger) (*Query, error)

func CompileQuery(ctx context.Context, zctx *zed.Context, c Compiler, program ast.Op, readers []zio.Reader) (*Query, error)

func NewQuery(pctx *op.Context, puller zbuf.Puller, meters []zbuf.Meter) *Query

func (q *Query) AsProgressReadCloser() zbuf.ProgressReadCloser

func (q *Query) AsReader() zio.Reader

func (q *Query) Close() error

func (q *Query) Meter() zbuf.Meter

func (q *Query) Progress() zbuf.Progress

func (q *Query) Pull(done bool) (zbuf.Batch, error)