merge

Documentation

Index

• type Op
  • 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)

Types

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

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

func (*Op) Len

func (o *Op) Len() int

func (*Op) Less

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

func (*Op) Pop

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

func (*Op) Pull

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

func (*Op) Push

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

func (*Op) Read

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

func (*Op) Swap

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