exec

Documentation

Index

• func Compact(ctx context.Context, lk *lake.Root, pool *lake.Pool, branchName string, ...) (ksuid.KSUID, error)
• type BranchStats
  • func GetBranchStats(ctx context.Context, b *lake.Branch, snap commits.View) (info BranchStats, err error)
• type DeleteQuery
  • func NewDeleteQuery(rctx *runtime.Context, puller zbuf.Puller, deletes *sync.Map) *DeleteQuery
  • func (d *DeleteQuery) DeletionSet() []ksuid.KSUID
• type PoolStats
  • func GetPoolStats(ctx context.Context, p *lake.Pool, snap commits.View) (info PoolStats, err error)
• type Query
  • func NewQuery(rctx *runtime.Context, puller zbuf.Puller, meter zbuf.Meter) *Query
  • 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)

Functions

func Compact

func Compact(ctx context.Context, lk *lake.Root, pool *lake.Pool, branchName string, objectIDs []ksuid.KSUID, writeVectors bool, author, message, info string) (ksuid.KSUID, error)

Types

type BranchStats

type BranchStats struct {
	Size int64 `zed:"size"`
	// XXX (nibs) - This shouldn't be a span because keys don't have to be time.
	Span *nano.Span `zed:"span"`
}

func GetBranchStats

func GetBranchStats(ctx context.Context, b *lake.Branch, snap commits.View) (info BranchStats, err error)

type DeleteQuery

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

func NewDeleteQuery

func NewDeleteQuery(rctx *runtime.Context, puller zbuf.Puller, deletes *sync.Map) *DeleteQuery

func (*DeleteQuery) DeletionSet

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

type PoolStats

type PoolStats struct {
	Size int64 `zed:"size"`
	// XXX (nibs) - This shouldn't be a span because keys don't have to be time.
	Span *nano.Span `zed:"span"`
}

XXX for backward compat keep this for now, and return branchstats for pool/main

func GetPoolStats

func GetPoolStats(ctx context.Context, p *lake.Pool, snap commits.View) (info PoolStats, err 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 NewQuery

func NewQuery(rctx *runtime.Context, puller zbuf.Puller, meter zbuf.Meter) *Query

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)