join

Documentation

Index

• type Op
  • func New(rctx *runtime.Context, anti, inner bool, left, right zbuf.Puller, ...) (*Op, error)
  • func (o *Op) Pull(done bool) (zbuf.Batch, error)

Types

type Op

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

func New

func New(rctx *runtime.Context, anti, inner bool, left, right zbuf.Puller, leftKey, rightKey expr.Evaluator,
	leftDir, rightDir order.Direction, lhs []*expr.Lval,
	rhs []expr.Evaluator) (*Op, error)

func (*Op) Pull

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

Pull implements the merge logic for returning data from the upstreams.