dedupjoin

type DedupJoin struct {
	Result     []colexec.ResultPos
	LeftTypes  []types.Type
	RightTypes []types.Type
	Conditions [][]*plan.Expr

	IsShuffle          bool
	ShuffleIdx         int32
	RuntimeFilterSpecs []*plan.RuntimeFilterSpec
	JoinMapTag         int32

	Channel  chan *WorkerJoinMsg
	NumCPU   uint64
	IsMerger bool

	OnDuplicateAction         plan.Node_OnDuplicateAction
	DedupBuildKeepLast        bool
	DedupColName              string
	DedupColTypes             []plan.Type
	DelColIdx                 int32
	DedupDeleteMarkerColIdx   int32
	DedupDeleteKeepColIdxList []int32
	UpdateColIdxList          []int32
	UpdateColExprList         []*plan.Expr

	// OldColCapturePlaceholderIdxList / OldColCaptureProbeIdxList are parallel
	// arrays. For each i, when probe hits a build bucket the probe-side column
	// at OldColCaptureProbeIdxList[i] is captured and, in finalize(), emitted
	// into every Result entry whose (Rel=1, Pos) equals
	// OldColCapturePlaceholderIdxList[i]. Used by the REPLACE INTO merged
	// main-table scan path; empty for regular INSERT/UPDATE.
	OldColCapturePlaceholderIdxList []int32
	OldColCaptureProbeIdxList       []int32

	vm.OperatorBase
	// contains filtered or unexported fields
}

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