runtime

Documentation

Index

• type Query
  • func NewQuery(pctx *op.Context, flowgraph *compiler.Runtime, closer io.Closer) *Query
  • func NewQueryOnFileSystem(ctx context.Context, zctx *zed.Context, program ast.Proc, readers []zio.Reader, ...) (*Query, error)
  • func NewQueryOnLake(ctx context.Context, zctx *zed.Context, program ast.Proc, lake op.DataAdaptor, ...) (*Query, error)
  • func NewQueryOnOrderedReader(ctx context.Context, zctx *zed.Context, program ast.Proc, reader zio.Reader, ...) (*Query, error)
  • func NewQueryOnReader(ctx context.Context, zctx *zed.Context, program ast.Proc, reader zio.Reader, ...) (*Query, error)
  • func (q *Query) AsProgressReader() zbuf.ProgressReader
  • func (q *Query) AsReader() zio.Reader
  • func (q *Query) Close() error
  • func (q *Query) Meter() zbuf.Meter
  • func (q *Query) Progress() zbuf.Progress

Types

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 NewQuery

func NewQuery(pctx *op.Context, flowgraph *compiler.Runtime, closer io.Closer) *Query

func NewQueryOnFileSystem

func NewQueryOnFileSystem(ctx context.Context, zctx *zed.Context, program ast.Proc, readers []zio.Reader, adaptor op.DataAdaptor) (*Query, error)

func NewQueryOnLake

func NewQueryOnLake(ctx context.Context, zctx *zed.Context, program ast.Proc, lake op.DataAdaptor, head *lakeparse.Commitish, logger *zap.Logger) (*Query, error)

func NewQueryOnOrderedReader

func NewQueryOnOrderedReader(ctx context.Context, zctx *zed.Context, program ast.Proc, reader zio.Reader, layout order.Layout, logger *zap.Logger) (*Query, error)

func NewQueryOnReader

func NewQueryOnReader(ctx context.Context, zctx *zed.Context, program ast.Proc, reader zio.Reader, logger *zap.Logger) (*Query, error)

func (*Query) AsProgressReader

func (q *Query) AsProgressReader() zbuf.ProgressReader

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