Function NewJoinNaiveMerge

exec/join.go:130–143

A very stupid naive parallel join merge, uses Key() as value to merge two different input channels source1 -> \ -- join --> source2 -> Distributed: source1a -> |-> -- join --> source1b -> key-hash-route |-> -- join --> reduce -> source1n -> |-> -- joi

(ctx *plan.Context, l, r TaskRunner, p *plan.JoinMerge)

//   source2n  ->                |-> --  join  -->
//
func NewJoinNaiveMerge(ctx *plan.Context, l, r TaskRunner, p *plan.JoinMerge) *JoinMerge {

	m := &JoinMerge{
		TaskBase: NewTaskBase(ctx),
		colIndex: p.ColIndex,
	}

	m.ltask = l
	m.rtask = r
	m.leftStmt = p.LeftFrom
	m.rightStmt = p.RightFrom

	return m
}

func (m *JoinMerge) Run() error {
	defer m.Ctx.Recover()