| Line | Hits | Source | Commit |
|---|---|---|---|
| 2475 | - | * - per-variable match_start dependency (variables containing FIRST, | 7521a30Row pattern recognition patch (planner). |
| 2476 | - | * LAST-with-offset, or compound PREV_FIRST/NEXT_FIRST/PREV_LAST/ | 7521a30Row pattern recognition patch (planner). |
| 2477 | - | * NEXT_LAST-with-offset require per-context re-evaluation) | 7521a30Row pattern recognition patch (planner). |
| 2478 | - | * | 7521a30Row pattern recognition patch (planner). |
| 2479 | - | * The driver sets curVarIdx to the index of the variable being walked | 7521a30Row pattern recognition patch (planner). |
| 2480 | - | * before each invocation; the walker uses it to populate matchStartDependent. | 7521a30Row pattern recognition patch (planner). |
| 2481 | - | */ | 7521a30Row pattern recognition patch (planner). |
| 2482 | - | typedef struct DefineMetadataContext | 7521a30Row pattern recognition patch (planner). |
| 2483 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2484 | - | int64 maxOffset; /* max PREV/LAST backward offset (>= 0) */ | 7521a30Row pattern recognition patch (planner). |
| 2485 | - | bool maxNeedsEval; /* non-constant PREV/LAST offset found */ | 7521a30Row pattern recognition patch (planner). |
| 2486 | - | bool maxOverflow; /* constant offset overflow detected */ | 7521a30Row pattern recognition patch (planner). |
| 2487 | - | int64 firstOffset; /* min FIRST offset (may be negative for | 7521a30Row pattern recognition patch (planner). |
| 2488 | - | * PREV_FIRST) */ | 7521a30Row pattern recognition patch (planner). |
| 2489 | - | bool hasFirst; /* any FIRST node found */ | 7521a30Row pattern recognition patch (planner). |
| 2490 | - | bool firstNeedsEval; /* non-constant FIRST offset found */ | 7521a30Row pattern recognition patch (planner). |
| 2491 | - | int curVarIdx; /* DEFINE variable currently being walked */ | 7521a30Row pattern recognition patch (planner). |
| 2492 | - | Bitmapset *matchStartDependent; /* variables that depend on | 7521a30Row pattern recognition patch (planner). |
| 2493 | - | * match_start */ | 7521a30Row pattern recognition patch (planner). |
| 2494 | - | } DefineMetadataContext; | 7521a30Row pattern recognition patch (planner). |
| Line | Hits | Source | Commit |
|---|---|---|---|
| 2502 | 1370 | extract_const_offset(Expr *expr, int64 defaultOffset, int64 *result) | 7521a30Row pattern recognition patch (planner). |
| 2503 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2504 | 1370 | if (expr == NULL) | 7521a30Row pattern recognition patch (planner). |
| 2505 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2506 | 895 | *result = defaultOffset; | 7521a30Row pattern recognition patch (planner). |
| 2507 | 895 | return true; | 7521a30Row pattern recognition patch (planner). |
| 2508 | - | } | 7521a30Row pattern recognition patch (planner). |
| 2509 | - | 7521a30Row pattern recognition patch (planner). | |
| 2510 | 475 | if (IsA(expr, Const)) | 7521a30Row pattern recognition patch (planner). |
| 2511 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2512 | 430 | Const *c = (Const *) expr; | 7521a30Row pattern recognition patch (planner). |
| 2513 | - | 7521a30Row pattern recognition patch (planner). | |
| 2514 | 430 | if (c->constisnull) | 7521a30Row pattern recognition patch (planner). |
| 2515 | 40 | *result = 0; /* runtime error; safe placeholder */ | 7521a30Row pattern recognition patch (planner). |
| 2516 | - | else | 7521a30Row pattern recognition patch (planner). |
| 2517 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2518 | 390 | *result = DatumGetInt64(c->constvalue); | 7521a30Row pattern recognition patch (planner). |
| 2519 | 390 | if (*result < 0) | 7521a30Row pattern recognition patch (planner). |
| 2520 | 35 | *result = 0; /* runtime error; safe placeholder */ | 7521a30Row pattern recognition patch (planner). |
| 2521 | - | } | 7521a30Row pattern recognition patch (planner). |
| 2522 | 430 | return true; | 7521a30Row pattern recognition patch (planner). |
| 2523 | - | } | 7521a30Row pattern recognition patch (planner). |
| 2524 | - | 7521a30Row pattern recognition patch (planner). | |
| 2525 | - | return false; /* non-constant */ | 7521a30Row pattern recognition patch (planner). |
| 2526 | - | } | 7521a30Row pattern recognition patch (planner). |
| Line | Hits | Source | Commit |
|---|---|---|---|
| 2555 | 1320 | visit_nav_plan(NavTraversal *t, RPRNavExpr *nav) | 7521a30Row pattern recognition patch (planner). |
| 2556 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2557 | 1320 | DefineMetadataContext *context = (DefineMetadataContext *) t->data; | 7521a30Row pattern recognition patch (planner). |
| 2558 | - | 7521a30Row pattern recognition patch (planner). | |
| 2559 | - | /* | 7521a30Row pattern recognition patch (planner). |
| 2560 | - | * Parser guarantee: by the time the planner sees a DEFINE expression, | 7521a30Row pattern recognition patch (planner). |
| 2561 | - | * compound nesting has been flattened into a single RPRNavExpr and any | 7521a30Row pattern recognition patch (planner). |
| 2562 | - | * other RPRNavExpr nesting has been rejected. So nav's direct child | 7521a30Row pattern recognition patch (planner). |
| 2563 | - | * fields are not themselves RPRNavExpr nodes, and outer-kind dispatch | 7521a30Row pattern recognition patch (planner). |
| 2564 | - | * below is sufficient. | 7521a30Row pattern recognition patch (planner). |
| 2565 | - | */ | 7521a30Row pattern recognition patch (planner). |
| 2566 | 1320 | Assert(nav->arg == NULL || !IsA(nav->arg, RPRNavExpr)); | 7521a30Row pattern recognition patch (planner). |
| 2567 | 1320 | Assert(nav->offset_arg == NULL || !IsA(nav->offset_arg, RPRNavExpr)); | 7521a30Row pattern recognition patch (planner). |
| 2568 | 1320 | Assert(nav->compound_offset_arg == NULL || | 7521a30Row pattern recognition patch (planner). |
| 2569 | - | !IsA(nav->compound_offset_arg, RPRNavExpr)); | 7521a30Row pattern recognition patch (planner). |
| 2570 | - | 7521a30Row pattern recognition patch (planner). | |
| 2571 | - | /* | 7521a30Row pattern recognition patch (planner). |
| 2572 | - | * Simple PREV(v, N) and LAST(v, N): backward reach from currentpos. LAST | 7521a30Row pattern recognition patch (planner). |
| 2573 | - | * without offset = currentpos, no backward reach. NEXT: forward only, | 7521a30Row pattern recognition patch (planner). |
| 2574 | - | * irrelevant for trim. | 7521a30Row pattern recognition patch (planner). |
| 2575 | - | */ | 7521a30Row pattern recognition patch (planner). |
| 2576 | 1320 | if (nav->kind == RPR_NAV_PREV || | 7521a30Row pattern recognition patch (planner). |
| 2577 | 70 | (nav->kind == RPR_NAV_LAST && nav->offset_arg != NULL)) | 7521a30Row pattern recognition patch (planner). |
| 2578 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2579 | 950 | if (!context->maxNeedsEval) | 7521a30Row pattern recognition patch (planner). |
| 2580 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2581 | 950 | int64 offset; | 7521a30Row pattern recognition patch (planner). |
| 2582 | - | 7521a30Row pattern recognition patch (planner). | |
| 2583 | - | /* | 7521a30Row pattern recognition patch (planner). |
| 2584 | - | * default 1 is for PREV; the guarded LAST sub-case never uses it. | 7521a30Row pattern recognition patch (planner). |
| 2585 | - | */ | 7521a30Row pattern recognition patch (planner). |
| 2586 | 950 | if (extract_const_offset(nav->offset_arg, 1, &offset)) | 7521a30Row pattern recognition patch (planner). |
| 2587 | 935 | context->maxOffset = Max(context->maxOffset, offset); | 7521a30Row pattern recognition patch (planner). |
| 2588 | - | else | 7521a30Row pattern recognition patch (planner). |
| 2589 | 15 | context->maxNeedsEval = true; | 7521a30Row pattern recognition patch (planner). |
| 2590 | - | } | 7521a30Row pattern recognition patch (planner). |
| 2591 | - | } | 7521a30Row pattern recognition patch (planner). |
| 2592 | - | 7521a30Row pattern recognition patch (planner). | |
| 2593 | - | /* | 7521a30Row pattern recognition patch (planner). |
| 2594 | - | * Simple FIRST(v, N): forward reach from match_start. Smaller N means | 7521a30Row pattern recognition patch (planner). |
| 2595 | - | * older rows needed. | 7521a30Row pattern recognition patch (planner). |
| 2596 | - | */ | 7521a30Row pattern recognition patch (planner). |
| 2597 | 1320 | if (nav->kind == RPR_NAV_FIRST) | 7521a30Row pattern recognition patch (planner). |
| 2598 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2599 | 65 | context->hasFirst = true; | 7521a30Row pattern recognition patch (planner). |
| 2600 | - | 7521a30Row pattern recognition patch (planner). | |
| 2601 | 65 | if (!context->firstNeedsEval) | 7521a30Row pattern recognition patch (planner). |
| 2602 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2603 | 65 | int64 offset; | 7521a30Row pattern recognition patch (planner). |
| 2604 | - | 7521a30Row pattern recognition patch (planner). | |
| 2605 | 65 | if (extract_const_offset(nav->offset_arg, 0, &offset)) | 7521a30Row pattern recognition patch (planner). |
| 2606 | 60 | context->firstOffset = Min(context->firstOffset, offset); | 7521a30Row pattern recognition patch (planner). |
| 2607 | - | else | 7521a30Row pattern recognition patch (planner). |
| 2608 | 5 | context->firstNeedsEval = true; | 7521a30Row pattern recognition patch (planner). |
| 2609 | - | } | 7521a30Row pattern recognition patch (planner). |
| 2610 | - | } | 7521a30Row pattern recognition patch (planner). |
| 2611 | - | 7521a30Row pattern recognition patch (planner). | |
| 2612 | - | /* | 7521a30Row pattern recognition patch (planner). |
| 2613 | - | * Compound PREV_LAST / NEXT_LAST: base = currentpos. PREV_LAST(v, N, M): | 7521a30Row pattern recognition patch (planner). |
| 2614 | - | * target = currentpos - N - M -> lookback = N + M NEXT_LAST(v, N, M): | 7521a30Row pattern recognition patch (planner). |
| 2615 | - | * target = currentpos - N + M -> lookback = max(N - M, 0) | 7521a30Row pattern recognition patch (planner). |
| 2616 | - | */ | 7521a30Row pattern recognition patch (planner). |
| 2617 | 1320 | if (nav->kind == RPR_NAV_PREV_LAST || | 7521a30Row pattern recognition patch (planner). |
| 2618 | - | nav->kind == RPR_NAV_NEXT_LAST) | 7521a30Row pattern recognition patch (planner). |
| 2619 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2620 | 65 | if (!context->maxNeedsEval) | 7521a30Row pattern recognition patch (planner). |
| 2621 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2622 | 65 | int64 inner; | 7521a30Row pattern recognition patch (planner). |
| 2623 | 65 | int64 outer; | 7521a30Row pattern recognition patch (planner). |
| 2624 | 65 | int64 reach; | 7521a30Row pattern recognition patch (planner). |
| 2625 | - | 7521a30Row pattern recognition patch (planner). | |
| 2626 | 120 | if (extract_const_offset(nav->offset_arg, 0, &inner) && | 7521a30Row pattern recognition patch (planner). |
| 2627 | 55 | extract_const_offset(nav->compound_offset_arg, 1, &outer)) | 7521a30Row pattern recognition patch (planner). |
| 2628 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2629 | 55 | if (nav->kind == RPR_NAV_PREV_LAST) | 7521a30Row pattern recognition patch (planner). |
| 2630 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2631 | 20 | if (pg_add_s64_overflow(inner, outer, &reach)) | 7521a30Row pattern recognition patch (planner). |
| 2632 | 5 | context->maxOverflow = true; | 7521a30Row pattern recognition patch (planner). |
| 2633 | - | else | 7521a30Row pattern recognition patch (planner). |
| 2634 | 15 | context->maxOffset = Max(context->maxOffset, reach); | 7521a30Row pattern recognition patch (planner). |
| 2635 | - | } | 7521a30Row pattern recognition patch (planner). |
| 2636 | - | else | 7521a30Row pattern recognition patch (planner). |
| 2637 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2638 | 35 | reach = Max(inner - outer, 0); | 7521a30Row pattern recognition patch (planner). |
| 2639 | 35 | context->maxOffset = Max(context->maxOffset, reach); | 7521a30Row pattern recognition patch (planner). |
| 2640 | - | } | 7521a30Row pattern recognition patch (planner). |
| 2641 | - | } | 7521a30Row pattern recognition patch (planner). |
| 2642 | - | else | 7521a30Row pattern recognition patch (planner). |
| 2643 | 10 | context->maxNeedsEval = true; | 7521a30Row pattern recognition patch (planner). |
| 2644 | - | } | 7521a30Row pattern recognition patch (planner). |
| 2645 | - | } | 7521a30Row pattern recognition patch (planner). |
| 2646 | - | 7521a30Row pattern recognition patch (planner). | |
| 2647 | - | /* | 7521a30Row pattern recognition patch (planner). |
| 2648 | - | * Compound PREV_FIRST / NEXT_FIRST: base = match_start. PREV_FIRST(v, N, | 7521a30Row pattern recognition patch (planner). |
| 2649 | - | * M): target = match_start + N - M NEXT_FIRST(v, N, M): target = | 7521a30Row pattern recognition patch (planner). |
| 2650 | - | * match_start + N + M The combined offset (N+/-M) from match_start can be | 7521a30Row pattern recognition patch (planner). |
| 2651 | - | * negative, meaning rows before match_start are needed. | 7521a30Row pattern recognition patch (planner). |
| 2652 | - | */ | 7521a30Row pattern recognition patch (planner). |
| 2653 | 1320 | if (nav->kind == RPR_NAV_PREV_FIRST || | 7521a30Row pattern recognition patch (planner). |
| 2654 | - | nav->kind == RPR_NAV_NEXT_FIRST) | 7521a30Row pattern recognition patch (planner). |
| 2655 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2656 | 125 | context->hasFirst = true; | 7521a30Row pattern recognition patch (planner). |
| 2657 | - | 7521a30Row pattern recognition patch (planner). | |
| 2658 | 125 | if (!context->firstNeedsEval) | 7521a30Row pattern recognition patch (planner). |
| 2659 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2660 | 125 | int64 inner; | 7521a30Row pattern recognition patch (planner). |
| 2661 | 125 | int64 outer; | 7521a30Row pattern recognition patch (planner). |
| 2662 | 125 | int64 reach; | 7521a30Row pattern recognition patch (planner). |
| 2663 | - | 7521a30Row pattern recognition patch (planner). | |
| 2664 | 235 | if (extract_const_offset(nav->offset_arg, 0, &inner) && | 7521a30Row pattern recognition patch (planner). |
| 2665 | 110 | extract_const_offset(nav->compound_offset_arg, 1, &outer)) | 7521a30Row pattern recognition patch (planner). |
| 2666 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2667 | 110 | if (nav->kind == RPR_NAV_PREV_FIRST) | 7521a30Row pattern recognition patch (planner). |
| 2668 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2669 | - | /* | 7521a30Row pattern recognition patch (planner). |
| 2670 | - | * reach = inner - outer. Both are non-negative, so the | 7521a30Row pattern recognition patch (planner). |
| 2671 | - | * result >= -PG_INT64_MAX, which cannot underflow int64. | 7521a30Row pattern recognition patch (planner). |
| 2672 | - | * No overflow check needed. | 7521a30Row pattern recognition patch (planner). |
| 2673 | - | */ | 7521a30Row pattern recognition patch (planner). |
| 2674 | 80 | reach = inner - outer; | 7521a30Row pattern recognition patch (planner). |
| 2675 | - | } | 7521a30Row pattern recognition patch (planner). |
| 2676 | - | else | 7521a30Row pattern recognition patch (planner). |
| 2677 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2678 | - | /* | 7521a30Row pattern recognition patch (planner). |
| 2679 | - | * NEXT_FIRST: reach = inner + outer. This can overflow, | 7521a30Row pattern recognition patch (planner). |
| 2680 | - | * but the result is always >= 0, so it never updates | 7521a30Row pattern recognition patch (planner). |
| 2681 | - | * firstOffset (which tracks the minimum). Clamp to | 7521a30Row pattern recognition patch (planner). |
| 2682 | - | * PG_INT64_MAX on overflow. | 7521a30Row pattern recognition patch (planner). |
| 2683 | - | */ | 7521a30Row pattern recognition patch (planner). |
| 2684 | 30 | if (pg_add_s64_overflow(inner, outer, &reach)) | 7521a30Row pattern recognition patch (planner). |
| 2685 | 10 | reach = PG_INT64_MAX; | 7521a30Row pattern recognition patch (planner). |
| 2686 | - | } | 7521a30Row pattern recognition patch (planner). |
| 2687 | - | 7521a30Row pattern recognition patch (planner). | |
| 2688 | 110 | context->firstOffset = Min(context->firstOffset, reach); | 7521a30Row pattern recognition patch (planner). |
| 2689 | - | } | 7521a30Row pattern recognition patch (planner). |
| 2690 | - | else | 7521a30Row pattern recognition patch (planner). |
| 2691 | 15 | context->firstNeedsEval = true; | 7521a30Row pattern recognition patch (planner). |
| 2692 | - | } | 7521a30Row pattern recognition patch (planner). |
| 2693 | - | } | 7521a30Row pattern recognition patch (planner). |
| 2694 | - | 7521a30Row pattern recognition patch (planner). | |
| 2695 | - | /* | 7521a30Row pattern recognition patch (planner). |
| 2696 | - | * Match-start dependency: classify the outer nav kind. A constant | 7521a30Row pattern recognition patch (planner). |
| 2697 | - | * LAST(x, 0) is conservatively included (offset_arg is a non-NULL Const), | 7521a30Row pattern recognition patch (planner). |
| 2698 | - | * causing a harmless extra re-evaluation; since LAST(x, 0) is the current | 7521a30Row pattern recognition patch (planner). |
| 2699 | - | * row, its result is independent of the match start. | 7521a30Row pattern recognition patch (planner). |
| 2700 | - | */ | 7521a30Row pattern recognition patch (planner). |
| 2701 | 1320 | if (nav->kind == RPR_NAV_FIRST || | 7521a30Row pattern recognition patch (planner). |
| 2702 | 1255 | (nav->kind == RPR_NAV_LAST && nav->offset_arg != NULL) || | 7521a30Row pattern recognition patch (planner). |
| 2703 | 1140 | nav->kind == RPR_NAV_PREV_FIRST || | 7521a30Row pattern recognition patch (planner). |
| 2704 | 1100 | nav->kind == RPR_NAV_NEXT_FIRST || | 7521a30Row pattern recognition patch (planner). |
| 2705 | 1100 | ((nav->kind == RPR_NAV_PREV_LAST || | 7521a30Row pattern recognition patch (planner). |
| 2706 | 65 | nav->kind == RPR_NAV_NEXT_LAST) && | 7521a30Row pattern recognition patch (planner). |
| 2707 | 65 | nav->offset_arg != NULL)) | 7521a30Row pattern recognition patch (planner). |
| 2708 | 260 | context->matchStartDependent = | 7521a30Row pattern recognition patch (planner). |
| 2709 | 260 | bms_add_member(context->matchStartDependent, | 7521a30Row pattern recognition patch (planner). |
| 2710 | - | context->curVarIdx); | 7521a30Row pattern recognition patch (planner). |
| 2711 | 1320 | } | 7521a30Row pattern recognition patch (planner). |
| Line | Hits | Source | Commit |
|---|---|---|---|
| 2730 | 3793 | compute_define_metadata(List *defineClause, | 7521a30Row pattern recognition patch (planner). |
| 2731 | - | RPRNavOffsetKind *maxKind, int64 *maxResult, | 7521a30Row pattern recognition patch (planner). |
| 2732 | - | bool *hasFirst, | 7521a30Row pattern recognition patch (planner). |
| 2733 | - | RPRNavOffsetKind *firstKind, int64 *firstResult, | 7521a30Row pattern recognition patch (planner). |
| 2734 | - | Bitmapset **matchStartDependent) | 7521a30Row pattern recognition patch (planner). |
| 2735 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2736 | 3793 | DefineMetadataContext ctx; | 7521a30Row pattern recognition patch (planner). |
| 2737 | 3793 | NavTraversal trav; | 7521a30Row pattern recognition patch (planner). |
| 2738 | - | 7521a30Row pattern recognition patch (planner). | |
| 2739 | 3793 | ctx.maxOffset = 0; | 7521a30Row pattern recognition patch (planner). |
| 2740 | 3793 | ctx.maxNeedsEval = false; | 7521a30Row pattern recognition patch (planner). |
| 2741 | 3793 | ctx.maxOverflow = false; | 7521a30Row pattern recognition patch (planner). |
| 2742 | 3793 | ctx.firstOffset = PG_INT64_MAX; /* sentinel: no FIRST found yet */ | 7521a30Row pattern recognition patch (planner). |
| 2743 | 3793 | ctx.hasFirst = false; | 7521a30Row pattern recognition patch (planner). |
| 2744 | 3793 | ctx.firstNeedsEval = false; | 7521a30Row pattern recognition patch (planner). |
| 2745 | 3793 | ctx.curVarIdx = 0; | 7521a30Row pattern recognition patch (planner). |
| 2746 | 3793 | ctx.matchStartDependent = NULL; | 7521a30Row pattern recognition patch (planner). |
| 2747 | - | 7521a30Row pattern recognition patch (planner). | |
| 2748 | 3793 | trav.visit = visit_nav_plan; | 7521a30Row pattern recognition patch (planner). |
| 2749 | 3793 | trav.data = &ctx; | 7521a30Row pattern recognition patch (planner). |
| 2750 | - | 7521a30Row pattern recognition patch (planner). | |
| 2751 | 12540 | foreach_node(TargetEntry, te, defineClause) | 7521a30Row pattern recognition patch (planner). |
| 2752 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2753 | 8747 | nav_traversal_walker((Node *) te->expr, &trav); | 7521a30Row pattern recognition patch (planner). |
| 2754 | 8747 | ctx.curVarIdx++; | 7521a30Row pattern recognition patch (planner). |
| 2755 | - | } | 7521a30Row pattern recognition patch (planner). |
| 2756 | - | 7521a30Row pattern recognition patch (planner). | |
| 2757 | 3793 | *matchStartDependent = ctx.matchStartDependent; | 7521a30Row pattern recognition patch (planner). |
| 2758 | - | 7521a30Row pattern recognition patch (planner). | |
| 2759 | - | /* Max backward offset */ | 7521a30Row pattern recognition patch (planner). |
| 2760 | 3793 | if (ctx.maxOverflow) | 7521a30Row pattern recognition patch (planner). |
| 2761 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2762 | 5 | *maxKind = RPR_NAV_OFFSET_RETAIN_ALL; | 7521a30Row pattern recognition patch (planner). |
| 2763 | 5 | *maxResult = 0; | 7521a30Row pattern recognition patch (planner). |
| 2764 | - | } | 7521a30Row pattern recognition patch (planner). |
| 2765 | 3788 | else if (ctx.maxNeedsEval) | 7521a30Row pattern recognition patch (planner). |
| 2766 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2767 | 25 | *maxKind = RPR_NAV_OFFSET_NEEDS_EVAL; | 7521a30Row pattern recognition patch (planner). |
| 2768 | 25 | *maxResult = 0; | 7521a30Row pattern recognition patch (planner). |
| 2769 | - | } | 7521a30Row pattern recognition patch (planner). |
| 2770 | - | else | 7521a30Row pattern recognition patch (planner). |
| 2771 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2772 | 3763 | *maxKind = RPR_NAV_OFFSET_FIXED; | 7521a30Row pattern recognition patch (planner). |
| 2773 | 3763 | *maxResult = ctx.maxOffset; | 7521a30Row pattern recognition patch (planner). |
| 2774 | - | } | 7521a30Row pattern recognition patch (planner). |
| 2775 | - | 7521a30Row pattern recognition patch (planner). | |
| 2776 | - | /* First offset (can be negative for compound PREV_FIRST) */ | 7521a30Row pattern recognition patch (planner). |
| 2777 | 3793 | *hasFirst = ctx.hasFirst; | 7521a30Row pattern recognition patch (planner). |
| 2778 | 3793 | if (ctx.hasFirst) | 7521a30Row pattern recognition patch (planner). |
| 2779 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2780 | 190 | if (ctx.firstNeedsEval) | 7521a30Row pattern recognition patch (planner). |
| 2781 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2782 | 20 | *firstKind = RPR_NAV_OFFSET_NEEDS_EVAL; | 7521a30Row pattern recognition patch (planner). |
| 2783 | 20 | *firstResult = 0; | 7521a30Row pattern recognition patch (planner). |
| 2784 | - | } | 7521a30Row pattern recognition patch (planner). |
| 2785 | - | else | 7521a30Row pattern recognition patch (planner). |
| 2786 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2787 | 170 | *firstKind = RPR_NAV_OFFSET_FIXED; | 7521a30Row pattern recognition patch (planner). |
| 2788 | 170 | *firstResult = ctx.firstOffset; /* may be negative; PG_INT64_MAX | 7521a30Row pattern recognition patch (planner). |
| 2789 | - | * if overflowed */ | 7521a30Row pattern recognition patch (planner). |
| 2790 | - | } | 7521a30Row pattern recognition patch (planner). |
| 2791 | - | } | 7521a30Row pattern recognition patch (planner). |
| 2792 | - | else | 7521a30Row pattern recognition patch (planner). |
| 2793 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2794 | 3603 | *firstKind = RPR_NAV_OFFSET_FIXED; | 7521a30Row pattern recognition patch (planner). |
| 2795 | 3603 | *firstResult = 0; | 7521a30Row pattern recognition patch (planner). |
| 2796 | - | } | 7521a30Row pattern recognition patch (planner). |
| 2797 | 3793 | } | 7521a30Row pattern recognition patch (planner). |
| Line | Hits | Source | Commit |
|---|---|---|---|
| 2806 | - | create_windowagg_plan(PlannerInfo *root, WindowAggPath *best_path) | - |
| 2807 | - | { | - |
| 2808 | - | WindowAgg *plan; | - |
| 2809 | - | WindowClause *wc = best_path->winclause; | - |
| 2810 | - | int numPart = list_length(wc->partitionClause); | - |
| 2811 | - | int numOrder = list_length(wc->orderClause); | - |
| 2812 | - | Plan *subplan; | - |
| 2813 | - | List *tlist; | - |
| 2814 | - | int partNumCols; | - |
| 2815 | - | AttrNumber *partColIdx; | - |
| 2816 | - | Oid *partOperators; | - |
| 2817 | - | Oid *partCollations; | - |
| 2818 | - | int ordNumCols; | - |
| 2819 | - | AttrNumber *ordColIdx; | - |
| 2820 | - | Oid *ordOperators; | - |
| 2821 | - | Oid *ordCollations; | - |
| 2822 | - | ListCell *lc; | - |
| 2823 | 6260 | RPRPattern *compiledPattern = NULL; | 7521a30Row pattern recognition patch (planner). |
| 2824 | 6260 | Bitmapset *matchStartDependent = NULL; | 7521a30Row pattern recognition patch (planner). |
| 2825 | 6260 | RPRNavOffsetKind navMaxOffsetKind = RPR_NAV_OFFSET_FIXED; | 7521a30Row pattern recognition patch (planner). |
| 2826 | 6260 | int64 navMaxOffset = 0; | 7521a30Row pattern recognition patch (planner). |
| 2827 | 6260 | bool hasFirstNav = false; | 7521a30Row pattern recognition patch (planner). |
| 2828 | 6260 | RPRNavOffsetKind navFirstOffsetKind = RPR_NAV_OFFSET_FIXED; | 7521a30Row pattern recognition patch (planner). |
| 2829 | 6260 | int64 navFirstOffset = 0; | 7521a30Row pattern recognition patch (planner). |
| 2830 | - | 7521a30Row pattern recognition patch (planner). | |
| 2831 | - | - | |
| 2832 | - | /* | - |
| 2833 | - | * Choice of tlist here is motivated by the fact that WindowAgg will be | - |
| 2834 | - | * storing the input rows of window frames in a tuplestore; it therefore | - |
| 2835 | - | * behooves us to request a small tlist to avoid wasting space. We do of | - |
| 2836 | - | * course need grouping columns to be available. | - |
| 2837 | - | */ | - |
| 2838 | - | subplan = create_plan_recurse(root, best_path->subpath, | - |
| 2839 | - | CP_LABEL_TLIST | CP_SMALL_TLIST); | - |
| 2840 | - | - | |
| 2841 | - | tlist = build_path_tlist(root, &best_path->path); | - |
| 2842 | - | - | |
| 2843 | - | /* | - |
| 2844 | - | * Convert SortGroupClause lists into arrays of attr indexes and equality | - |
| 2845 | - | * operators, as wanted by executor. | - |
| 2846 | - | */ | - |
| 2847 | - | partColIdx = palloc_array(AttrNumber, numPart); | - |
| 2848 | - | partOperators = palloc_array(Oid, numPart); | - |
| 2849 | - | partCollations = palloc_array(Oid, numPart); | - |
| 2850 | - | - | |
| 2851 | - | partNumCols = 0; | - |
| 2852 | - | foreach(lc, wc->partitionClause) | - |
| 2853 | - | { | - |
| 2854 | - | SortGroupClause *sgc = (SortGroupClause *) lfirst(lc); | - |
| 2855 | - | TargetEntry *tle = get_sortgroupclause_tle(sgc, subplan->targetlist); | - |
| 2856 | - | - | |
| 2857 | - | Assert(OidIsValid(sgc->eqop)); | - |
| 2858 | - | partColIdx[partNumCols] = tle->resno; | - |
| 2859 | - | partOperators[partNumCols] = sgc->eqop; | - |
| 2860 | - | partCollations[partNumCols] = exprCollation((Node *) tle->expr); | - |
| 2861 | - | partNumCols++; | - |
| 2862 | - | } | - |
| 2863 | - | - | |
| 2864 | - | ordColIdx = palloc_array(AttrNumber, numOrder); | - |
| 2865 | - | ordOperators = palloc_array(Oid, numOrder); | - |
| 2866 | - | ordCollations = palloc_array(Oid, numOrder); | - |
| 2867 | - | - | |
| 2868 | - | ordNumCols = 0; | - |
| 2869 | - | foreach(lc, wc->orderClause) | - |
| 2870 | - | { | - |
| 2871 | - | SortGroupClause *sgc = (SortGroupClause *) lfirst(lc); | - |
| 2872 | - | TargetEntry *tle = get_sortgroupclause_tle(sgc, subplan->targetlist); | - |
| 2873 | - | - | |
| 2874 | - | Assert(OidIsValid(sgc->eqop)); | - |
| 2875 | - | ordColIdx[ordNumCols] = tle->resno; | - |
| 2876 | - | ordOperators[ordNumCols] = sgc->eqop; | - |
| 2877 | - | ordCollations[ordNumCols] = exprCollation((Node *) tle->expr); | - |
| 2878 | - | ordNumCols++; | - |
| 2879 | - | } | - |
| 2880 | - | - | |
| 2881 | - | /* Build RPR pattern */ | 7512d22Simplify row pattern compilation by passing the WindowClause |
| 2882 | 6260 | if (wc->rpPattern) | 7521a30Row pattern recognition patch (planner). |
| 2883 | - | { | 7521a30Row pattern recognition patch (planner). |
| 2884 | - | /* | 7521a30Row pattern recognition patch (planner). |
| 2885 | - | * Walk DEFINE once: collect nav offsets (for tuplestore trim) and the | 7521a30Row pattern recognition patch (planner). |
| 2886 | - | * bitmapset of match_start-dependent variables (for absorption | 7521a30Row pattern recognition patch (planner). |
| 2887 | - | * suppression in buildRPRPattern). | 7521a30Row pattern recognition patch (planner). |
| 2888 | - | */ | 7521a30Row pattern recognition patch (planner). |
| 2889 | 3793 | compute_define_metadata(wc->defineClause, | 7521a30Row pattern recognition patch (planner). |
| 2890 | - | &navMaxOffsetKind, &navMaxOffset, | 7521a30Row pattern recognition patch (planner). |
| 2891 | - | &hasFirstNav, | 7521a30Row pattern recognition patch (planner). |
| 2892 | - | &navFirstOffsetKind, &navFirstOffset, | 7521a30Row pattern recognition patch (planner). |
| 2893 | - | &matchStartDependent); | 7521a30Row pattern recognition patch (planner). |
| 2894 | - | 7521a30Row pattern recognition patch (planner). | |
| 2895 | - | /* Compile and optimize RPR patterns */ | 7521a30Row pattern recognition patch (planner). |
| 2896 | 3793 | compiledPattern = buildRPRPattern(wc, !bms_is_empty(matchStartDependent)); | 7512d22Simplify row pattern compilation by passing the WindowClause |
| 2897 | - | } | 7521a30Row pattern recognition patch (planner). |
| 2898 | - | 7521a30Row pattern recognition patch (planner). | |
| 2899 | - | /* And finally we can make the WindowAgg node */ | - |
| 2900 | - | plan = make_windowagg(tlist, | - |
| 2901 | - | wc, | - |
| 2902 | - | partNumCols, | - |
| 2903 | - | partColIdx, | - |
| 2904 | - | partOperators, | - |
| 2905 | - | partCollations, | - |
| 2906 | - | ordNumCols, | - |
| 2907 | - | ordColIdx, | - |
| 2908 | - | ordOperators, | - |
| 2909 | - | ordCollations, | - |
| 2910 | - | best_path->runCondition, | - |
| 2911 | - | compiledPattern, | 7521a30Row pattern recognition patch (planner). |
| 2912 | - | matchStartDependent, | 7521a30Row pattern recognition patch (planner). |
| 2913 | - | navMaxOffsetKind, | b848408Tidy up row pattern recognition plumbing |
| 2914 | - | navMaxOffset, | b848408Tidy up row pattern recognition plumbing |
| 2915 | - | hasFirstNav, | 7521a30Row pattern recognition patch (planner). |
| 2916 | - | navFirstOffsetKind, | b848408Tidy up row pattern recognition plumbing |
| 2917 | - | navFirstOffset, | b848408Tidy up row pattern recognition plumbing |
| 2918 | - | best_path->qual, | - |
| 2919 | - | best_path->topwindow, | - |
| 2920 | - | subplan); | - |
| 2921 | - | - | |
| 2922 | - | copy_generic_path_info(&plan->plan, (Path *) best_path); | - |
| 2923 | - | - | |
| 2924 | - | return plan; | - |
| 2925 | - | } | - |