top

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

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