top

type Proc ¶

type Proc 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(zctx *zed.Context, parent zbuf.Puller, limit int, fields []expr.Evaluator, flushEvery bool) *Proc

func (p *Proc) Pull(done bool) (zbuf.Batch, error)