runtime

Documentation

Index

• type Compiler
• type DeleteQuery
  • func NewDeleteQuery(octx *op.Context, puller zbuf.Puller, deletes *sync.Map) *DeleteQuery
  • func (d *DeleteQuery) DeletionSet() []ksuid.KSUID
• type Query
  • func CompileLakeQuery(ctx context.Context, zctx *zed.Context, c Compiler, program ast.Seq, ...) (*Query, error)
  • func CompileQuery(ctx context.Context, zctx *zed.Context, c Compiler, program ast.Seq, ...) (*Query, error)
  • func NewQuery(octx *op.Context, puller zbuf.Puller, meter 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)

Types

type Compiler

type Compiler interface {
	NewQuery(*op.Context, ast.Seq, []zio.Reader) (*Query, error)
	NewLakeQuery(*op.Context, ast.Seq, int, *lakeparse.Commitish) (*Query, error)
	NewLakeDeleteQuery(*op.Context, ast.Seq, *lakeparse.Commitish) (*DeleteQuery, error)
	Parse(string, ...string) (ast.Seq, error)
}

type DeleteQuery

type DeleteQuery struct {
	*Query
	// contains filtered or unexported fields
}

func NewDeleteQuery

func NewDeleteQuery(octx *op.Context, puller zbuf.Puller, deletes *sync.Map) *DeleteQuery

func (*DeleteQuery) DeletionSet

func (d *DeleteQuery) DeletionSet() []ksuid.KSUID

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

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

func CompileQuery

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

func NewQuery

func NewQuery(octx *op.Context, puller zbuf.Puller, meter zbuf.Meter) *Query

func (*Query) AsProgressReadCloser

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

func (*Query) AsReader

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

func (*Query) Close

func (q *Query) Close() error

func (*Query) Meter

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

func (*Query) Progress

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

func (*Query) Pull

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