top

type Proc ¶

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

Top is similar to proc.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(parent proc.Interface, limit int, fields []expr.Evaluator, flushEvery bool) *Proc

func (p *Proc) Done()

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