merge

type Op ¶

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

Proc merges multiple upstream Pullers into one downstream Puller. If the input streams are ordered according to the configured comparison, the output of Merger will have the same order. Each parent puller is run in its own goroutine so that deadlock is avoided when the upstream pullers would otherwise block waiting for an adjacent puller to finish but the Merger is waiting on the upstream puller.

func New(ctx context.Context, parents []zbuf.Puller, cmp expr.CompareFn) *Op

func (o *Op) Len() int

func (o *Op) Less(i, j int) bool

func (o *Op) Pop() interface{}

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

func (o *Op) Push(x interface{})

func (o *Op) Read() (*zed.Value, error)

func (o *Op) Swap(i, j int)