Lines Matching refs:mergestate
152 #define MarkInnerTuple(innerTupleSlot, mergestate) \ argument
153 ExecCopySlot((mergestate)->mj_MarkedTupleSlot, (innerTupleSlot))
295 MJEvalOuterValues(MergeJoinState *mergestate) in MJEvalOuterValues() argument
297 ExprContext *econtext = mergestate->mj_OuterEContext; in MJEvalOuterValues()
303 if (TupIsNull(mergestate->mj_OuterTupleSlot)) in MJEvalOuterValues()
310 econtext->ecxt_outertuple = mergestate->mj_OuterTupleSlot; in MJEvalOuterValues()
312 for (i = 0; i < mergestate->mj_NumClauses; i++) in MJEvalOuterValues()
314 MergeJoinClause clause = &mergestate->mj_Clauses[i]; in MJEvalOuterValues()
322 !mergestate->mj_FillOuter) in MJEvalOuterValues()
342 MJEvalInnerValues(MergeJoinState *mergestate, TupleTableSlot *innerslot) in MJEvalInnerValues() argument
344 ExprContext *econtext = mergestate->mj_InnerEContext; in MJEvalInnerValues()
359 for (i = 0; i < mergestate->mj_NumClauses; i++) in MJEvalInnerValues()
361 MergeJoinClause clause = &mergestate->mj_Clauses[i]; in MJEvalInnerValues()
369 !mergestate->mj_FillInner) in MJEvalInnerValues()
392 MJCompare(MergeJoinState *mergestate) in MJCompare() argument
396 ExprContext *econtext = mergestate->js.ps.ps_ExprContext; in MJCompare()
408 for (i = 0; i < mergestate->mj_NumClauses; i++) in MJCompare()
410 MergeJoinClause clause = &mergestate->mj_Clauses[i]; in MJCompare()
439 (nulleqnull || mergestate->mj_ConstFalseJoin)) in MJCompare()
547 ExecMergeTupleDumpOuter(MergeJoinState *mergestate) in ExecMergeTupleDumpOuter() argument
549 TupleTableSlot *outerSlot = mergestate->mj_OuterTupleSlot; in ExecMergeTupleDumpOuter()
559 ExecMergeTupleDumpInner(MergeJoinState *mergestate) in ExecMergeTupleDumpInner() argument
561 TupleTableSlot *innerSlot = mergestate->mj_InnerTupleSlot; in ExecMergeTupleDumpInner()
571 ExecMergeTupleDumpMarked(MergeJoinState *mergestate) in ExecMergeTupleDumpMarked() argument
573 TupleTableSlot *markedSlot = mergestate->mj_MarkedTupleSlot; in ExecMergeTupleDumpMarked()
583 ExecMergeTupleDump(MergeJoinState *mergestate) in ExecMergeTupleDump() argument
587 ExecMergeTupleDumpOuter(mergestate); in ExecMergeTupleDump()
588 ExecMergeTupleDumpInner(mergestate); in ExecMergeTupleDump()
589 ExecMergeTupleDumpMarked(mergestate); in ExecMergeTupleDump()
1438 MergeJoinState *mergestate; in ExecInitMergeJoin() local
1449 mergestate = makeNode(MergeJoinState); in ExecInitMergeJoin()
1450 mergestate->js.ps.plan = (Plan *) node; in ExecInitMergeJoin()
1451 mergestate->js.ps.state = estate; in ExecInitMergeJoin()
1452 mergestate->js.ps.ExecProcNode = ExecMergeJoin; in ExecInitMergeJoin()
1459 ExecAssignExprContext(estate, &mergestate->js.ps); in ExecInitMergeJoin()
1466 mergestate->mj_OuterEContext = CreateExprContext(estate); in ExecInitMergeJoin()
1467 mergestate->mj_InnerEContext = CreateExprContext(estate); in ExecInitMergeJoin()
1472 mergestate->js.ps.qual = in ExecInitMergeJoin()
1473 ExecInitQual(node->join.plan.qual, (PlanState *) mergestate); in ExecInitMergeJoin()
1474 mergestate->js.jointype = node->join.jointype; in ExecInitMergeJoin()
1475 mergestate->js.joinqual = in ExecInitMergeJoin()
1476 ExecInitQual(node->join.joinqual, (PlanState *) mergestate); in ExecInitMergeJoin()
1477 mergestate->mj_ConstFalseJoin = false; in ExecInitMergeJoin()
1488 mergestate->mj_SkipMarkRestore = node->skip_mark_restore; in ExecInitMergeJoin()
1490 outerPlanState(mergestate) = ExecInitNode(outerPlan(node), estate, eflags); in ExecInitMergeJoin()
1491 innerPlanState(mergestate) = ExecInitNode(innerPlan(node), estate, in ExecInitMergeJoin()
1492 mergestate->mj_SkipMarkRestore ? in ExecInitMergeJoin()
1512 !mergestate->mj_SkipMarkRestore) in ExecInitMergeJoin()
1513 mergestate->mj_ExtraMarks = true; in ExecInitMergeJoin()
1515 mergestate->mj_ExtraMarks = false; in ExecInitMergeJoin()
1520 ExecInitResultTupleSlot(estate, &mergestate->js.ps); in ExecInitMergeJoin()
1522 mergestate->mj_MarkedTupleSlot = ExecInitExtraTupleSlot(estate); in ExecInitMergeJoin()
1523 ExecSetSlotDescriptor(mergestate->mj_MarkedTupleSlot, in ExecInitMergeJoin()
1524 ExecGetResultType(innerPlanState(mergestate))); in ExecInitMergeJoin()
1529 mergestate->js.single_match = (node->join.inner_unique || in ExecInitMergeJoin()
1537 mergestate->mj_FillOuter = false; in ExecInitMergeJoin()
1538 mergestate->mj_FillInner = false; in ExecInitMergeJoin()
1542 mergestate->mj_FillOuter = true; in ExecInitMergeJoin()
1543 mergestate->mj_FillInner = false; in ExecInitMergeJoin()
1544 mergestate->mj_NullInnerTupleSlot = in ExecInitMergeJoin()
1546 ExecGetResultType(innerPlanState(mergestate))); in ExecInitMergeJoin()
1549 mergestate->mj_FillOuter = false; in ExecInitMergeJoin()
1550 mergestate->mj_FillInner = true; in ExecInitMergeJoin()
1551 mergestate->mj_NullOuterTupleSlot = in ExecInitMergeJoin()
1553 ExecGetResultType(outerPlanState(mergestate))); in ExecInitMergeJoin()
1560 &mergestate->mj_ConstFalseJoin)) in ExecInitMergeJoin()
1566 mergestate->mj_FillOuter = true; in ExecInitMergeJoin()
1567 mergestate->mj_FillInner = true; in ExecInitMergeJoin()
1568 mergestate->mj_NullOuterTupleSlot = in ExecInitMergeJoin()
1570 ExecGetResultType(outerPlanState(mergestate))); in ExecInitMergeJoin()
1571 mergestate->mj_NullInnerTupleSlot = in ExecInitMergeJoin()
1573 ExecGetResultType(innerPlanState(mergestate))); in ExecInitMergeJoin()
1580 &mergestate->mj_ConstFalseJoin)) in ExecInitMergeJoin()
1593 ExecAssignResultTypeFromTL(&mergestate->js.ps); in ExecInitMergeJoin()
1594 ExecAssignProjectionInfo(&mergestate->js.ps, NULL); in ExecInitMergeJoin()
1599 mergestate->mj_NumClauses = list_length(node->mergeclauses); in ExecInitMergeJoin()
1600 mergestate->mj_Clauses = MJExamineQuals(node->mergeclauses, in ExecInitMergeJoin()
1605 (PlanState *) mergestate); in ExecInitMergeJoin()
1610 mergestate->mj_JoinState = EXEC_MJ_INITIALIZE_OUTER; in ExecInitMergeJoin()
1611 mergestate->mj_MatchedOuter = false; in ExecInitMergeJoin()
1612 mergestate->mj_MatchedInner = false; in ExecInitMergeJoin()
1613 mergestate->mj_OuterTupleSlot = NULL; in ExecInitMergeJoin()
1614 mergestate->mj_InnerTupleSlot = NULL; in ExecInitMergeJoin()
1622 return mergestate; in ExecInitMergeJoin()