top

Documentation

Index

• type Op
  • func New(zctx *zed.Context, parent zbuf.Puller, limit int, fields []expr.Evaluator, ...) *Op
  • func (o *Op) Pull(done bool) (zbuf.Batch, error)

Types

type Op

type Op struct {
	// contains filtered or unexported fields
}

Top is similar to op.Sort with a view key differences: - It only sorts in descending order. - It utilizes a MaxHeap, immediately discarding records that are not in the top N of the sort. - It has a hidden option (FlushEvery) to sort and emit on every batch.

func New

func New(zctx *zed.Context, parent zbuf.Puller, limit int, fields []expr.Evaluator, flushEvery bool) *Op

func (*Op) Pull

func (o *Op) Pull(done bool) (zbuf.Batch, error)