173 Datum *result,
bool *isnull);
178 Datum *result,
bool *isnull);
277 &fcinfo->args[
i].isnull);
288 for (
i = 1;
i <= numArguments;
i++)
290 if (fcinfo->args[
i].isnull)
341 (
void *) winstate, NULL);
342 fcinfo->args[0].value = peraggstate->
transValue;
354 (
errcode(ERRCODE_NULL_VALUE_NOT_ALLOWED),
355 errmsg(
"moving-aggregate transition function must not return null")));
453 &fcinfo->args[
i].isnull);
464 for (
i = 1;
i <= numArguments;
i++)
466 if (fcinfo->args[
i].isnull)
486 elog(
ERROR,
"aggregate transition value is NULL before inverse transition");
511 (
void *) winstate, NULL);
512 fcinfo->args[0].value = peraggstate->
transValue;
582 Datum *result,
bool *isnull)
601 (
void *) winstate, NULL);
602 fcinfo->args[0].value =
610 for (
i = 1;
i < numFinalArgs;
i++)
612 fcinfo->args[
i].value = (
Datum) 0;
613 fcinfo->args[
i].isnull =
true;
617 if (fcinfo->flinfo->fn_strict && anynull)
625 winstate->curaggcontext = peraggstate->
aggcontext;
627 winstate->curaggcontext = NULL;
628 *isnull = fcinfo->isnull;
669 int64 aggregatedupto_nonrestarted;
737 elog(
ERROR,
"window frame head moved backward");
757 for (
i = 0;
i < numaggs;
i++)
759 peraggstate = &winstate->
peragg[
i];
760 wfuncno = peraggstate->
wfuncno;
783 for (
i = 0;
i < numaggs;
i++)
785 peraggstate = &winstate->
peragg[
i];
806 while (numaggs_restart < numaggs &&
815 elog(
ERROR,
"could not re-fetch previously fetched frame row");
824 for (
i = 0;
i < numaggs;
i++)
828 peraggstate = &winstate->
peragg[
i];
832 wfuncno = peraggstate->
wfuncno;
876 if (numaggs_restart > 0)
878 for (
i = 0;
i < numaggs;
i++)
880 peraggstate = &winstate->
peragg[
i];
884 numaggs_restart == 0 ||
889 wfuncno = peraggstate->
wfuncno;
914 if (numaggs_restart > 0 &&
954 for (
i = 0;
i < numaggs;
i++)
956 peraggstate = &winstate->
peragg[
i];
963 wfuncno = peraggstate->
wfuncno;
979 Assert(aggregatedupto_nonrestarted <= winstate->aggregatedupto);
984 for (
i = 0;
i < numaggs;
i++)
989 peraggstate = &winstate->
peragg[
i];
990 wfuncno = peraggstate->
wfuncno;
1033 Datum *result,
bool *isnull)
1049 (
void *) perfuncstate->
winobj, NULL);
1051 for (
int argno = 0; argno < perfuncstate->
numArguments; argno++)
1052 fcinfo->args[argno].isnull =
true;
1057 *isnull = fcinfo->isnull;
1142 int readptr_flags = 0;
1168 for (
i = 0;
i < numfuncs;
i++)
1342 if (perfuncstate->
winobj)
1394 if (pos < winstate->frameheadpos)
1463 if (pos < winstate->grouptailpos)
1535 elog(
ERROR,
"unexpected end of tuplestore");
1616 elog(
ERROR,
"unexpected end of tuplestore");
1630 if (headisnull || currisnull)
1636 if (!headisnull || currisnull)
1642 if (headisnull || !currisnull)
1692 elog(
ERROR,
"unexpected end of tuplestore");
1788 elog(
ERROR,
"unexpected end of tuplestore");
1870 elog(
ERROR,
"unexpected end of tuplestore");
1884 if (tailisnull || currisnull)
1946 elog(
ERROR,
"unexpected end of tuplestore");
2079 (
errcode(ERRCODE_NULL_VALUE_NOT_ALLOWED),
2080 errmsg(
"frame starting offset must not be null")));
2092 (
errcode(ERRCODE_INVALID_PRECEDING_OR_FOLLOWING_SIZE),
2093 errmsg(
"frame starting offset must not be negative")));
2104 (
errcode(ERRCODE_NULL_VALUE_NOT_ALLOWED),
2105 errmsg(
"frame ending offset must not be null")));
2117 (
errcode(ERRCODE_INVALID_PRECEDING_OR_FOLLOWING_SIZE),
2118 errmsg(
"frame ending offset must not be negative")));
2127 if (winstate->
buffer == NULL)
2201 elog(
ERROR,
"unexpected end of tuplestore");
2215 elog(
ERROR,
"unexpected end of tuplestore");
2225 for (
i = 0;
i < numfuncs;
i++)
2392 "WindowAgg Partition",
2403 "WindowAgg Aggregates",
2524 winstate->
peragg = peragg;
2528 foreach(l, winstate->
funcs)
2537 elog(
ERROR,
"WindowFunc with winref %u assigned to WindowAgg with winref %u",
2541 for (
i = 0;
i <= wfuncno;
i++)
2543 if (
equal(wfunc, perfunc[
i].wfunc) &&
2555 perfuncstate = &perfunc[++wfuncno];
2558 wfuncstate->
wfuncno = wfuncno;
2570 perfuncstate->
wfunc = wfunc;
2587 perfuncstate->
aggno = ++aggno;
2588 peraggstate = &winstate->
peragg[aggno];
2590 peraggstate->
wfuncno = wfuncno;
2599 perfuncstate->
winobj = winobj;
2610 winstate->
numaggs = aggno + 1;
2769 foreach(lc, wfunc->
args)
2776 elog(
ERROR,
"cache lookup failed for aggregate %u",
2793 use_ma_code =
false;
2794 else if (aggform->aggmfinalmodify == AGGMODIFY_READ_ONLY &&
2795 aggform->aggfinalmodify != AGGMODIFY_READ_ONLY)
2798 use_ma_code =
false;
2800 use_ma_code =
false;
2805 peraggstate->
transfn_oid = transfn_oid = aggform->aggmtransfn;
2806 peraggstate->
invtransfn_oid = invtransfn_oid = aggform->aggminvtransfn;
2807 peraggstate->
finalfn_oid = finalfn_oid = aggform->aggmfinalfn;
2808 finalextra = aggform->aggmfinalextra;
2809 finalmodify = aggform->aggmfinalmodify;
2810 aggtranstype = aggform->aggmtranstype;
2811 initvalAttNo = Anum_pg_aggregate_aggminitval;
2815 peraggstate->
transfn_oid = transfn_oid = aggform->aggtransfn;
2817 peraggstate->
finalfn_oid = finalfn_oid = aggform->aggfinalfn;
2818 finalextra = aggform->aggfinalextra;
2819 finalmodify = aggform->aggfinalmodify;
2820 aggtranstype = aggform->aggtranstype;
2821 initvalAttNo = Anum_pg_aggregate_agginitval;
2837 elog(
ERROR,
"cache lookup failed for function %u",
2875 if (finalmodify != AGGMODIFY_READ_ONLY)
2877 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
2878 errmsg(
"aggregate function %s does not support use as a window function",
2958 if (numArguments < 1 ||
2961 (
errcode(ERRCODE_INVALID_FUNCTION_DEFINITION),
2962 errmsg(
"aggregate %u needs to have compatible input type and transition type",
2977 (
errcode(ERRCODE_INVALID_FUNCTION_DEFINITION),
2978 errmsg(
"strictness of aggregate's forward and inverse transition functions must match")));
2997 "WindowAgg Per Aggregate",
3040 econtext->ecxt_outertuple = slot1;
3041 econtext->ecxt_innertuple = slot2;
3071 if (pos < winobj->markpos)
3072 elog(
ERROR,
"cannot fetch row before WindowObject's mark position");
3081 if (winobj->
seekpos < pos - 1)
3086 elog(
ERROR,
"unexpected end of tuplestore");
3089 else if (winobj->
seekpos > pos + 1)
3094 elog(
ERROR,
"unexpected end of tuplestore");
3097 else if (winobj->
seekpos == pos)
3117 elog(
ERROR,
"unexpected end of tuplestore");
3123 elog(
ERROR,
"unexpected end of tuplestore");
3208 if (markpos < winobj->markpos)
3209 elog(
ERROR,
"cannot move WindowObject's mark position backward");
3211 if (markpos > winobj->
markpos)
3219 if (markpos > winobj->
seekpos)
3294 int relpos,
int seektype,
bool set_mark,
3295 bool *isnull,
bool *isout)
3321 elog(
ERROR,
"unrecognized window seek type: %d", seektype);
3382 int relpos,
int seektype,
bool set_mark,
3383 bool *isnull,
bool *isout)
3399 elog(
ERROR,
"WINDOW_SEEK_CURRENT is not supported for WinGetFuncArgInFrame");
3400 abs_pos = mark_pos = 0;
3451 if (abs_pos == overlapstart)
3458 elog(
ERROR,
"unrecognized frame option state: 0x%x",
3486 if (abs_pos <= winstate->currentpos &&
3490 if (abs_pos < winstate->frameheadpos)
3496 if (abs_pos < winstate->grouptailpos &&
3505 if (abs_pos < winstate->frameheadpos)
3511 if (abs_pos < winstate->grouptailpos &&
3517 if (abs_pos == overlapend - 1)
3523 if (abs_pos < winstate->frameheadpos)
3528 elog(
ERROR,
"unrecognized frame option state: 0x%x",
3535 elog(
ERROR,
"unrecognized window seek type: %d", seektype);
3536 abs_pos = mark_pos = 0;
void aclcheck_error(AclResult aclerr, ObjectType objtype, const char *objectname)
AclResult pg_proc_aclcheck(Oid proc_oid, Oid roleid, AclMode mode)
#define TextDatumGetCString(d)
#define MemSet(start, val, len)
#define OidIsValid(objectId)
bool contain_volatile_functions(Node *clause)
Datum datumCopy(Datum value, bool typByVal, int typLen)
static void PGresult * res
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
bool equal(const void *a, const void *b)
void ExecReScan(PlanState *node)
ExprState * ExecInitQual(List *qual, PlanState *parent)
ExprState * ExecInitExpr(Expr *node, PlanState *parent)
ExprState * execTuplesMatchPrepare(TupleDesc desc, int numCols, const AttrNumber *keyColIdx, const Oid *eqOperators, const Oid *collations, PlanState *parent)
void ExecEndNode(PlanState *node)
PlanState * ExecInitNode(Plan *node, EState *estate, int eflags)
const TupleTableSlotOps TTSOpsVirtual
TupleTableSlot * ExecInitExtraTupleSlot(EState *estate, TupleDesc tupledesc, const TupleTableSlotOps *tts_ops)
void ExecInitResultTupleSlotTL(PlanState *planstate, const TupleTableSlotOps *tts_ops)
const TupleTableSlotOps TTSOpsMinimalTuple
void ExecCreateScanSlotFromOuterPlan(EState *estate, ScanState *scanstate, const TupleTableSlotOps *tts_ops)
void ExecAssignExprContext(EState *estate, PlanState *planstate)
void ExecAssignProjectionInfo(PlanState *planstate, TupleDesc inputDesc)
void ExecFreeExprContext(PlanState *planstate)
struct WindowStatePerAggData * WindowStatePerAgg
#define InstrCountFiltered1(node, delta)
#define outerPlanState(node)
@ WINDOWAGG_PASSTHROUGH_STRICT
struct WindowStatePerFuncData * WindowStatePerFunc
#define EXEC_FLAG_BACKWARD
static TupleTableSlot * ExecProject(ProjectionInfo *projInfo)
#define ResetExprContext(econtext)
static bool ExecQual(ExprState *state, ExprContext *econtext)
static bool ExecQualAndReset(ExprState *state, ExprContext *econtext)
static Datum ExecEvalExpr(ExprState *state, ExprContext *econtext, bool *isNull)
static Datum ExecEvalExprSwitchContext(ExprState *state, ExprContext *econtext, bool *isNull)
static TupleTableSlot * ExecProcNode(PlanState *node)
ExpandedObjectHeader * DatumGetEOHP(Datum d)
void DeleteExpandedObject(Datum d)
#define MakeExpandedObjectReadOnly(d, isnull, typlen)
#define DatumIsReadWriteExpandedObject(d, isnull, typlen)
void fmgr_info(Oid functionId, FmgrInfo *finfo)
Datum OidInputFunctionCall(Oid functionId, char *str, Oid typioparam, int32 typmod)
Datum FunctionCall5Coll(FmgrInfo *flinfo, Oid collation, Datum arg1, Datum arg2, Datum arg3, Datum arg4, Datum arg5)
void fmgr_info_cxt(Oid functionId, FmgrInfo *finfo, MemoryContext mcxt)
#define InitFunctionCallInfoData(Fcinfo, Flinfo, Nargs, Collation, Context, Resultinfo)
#define LOCAL_FCINFO(name, nargs)
#define FunctionCallInvoke(fcinfo)
#define fmgr_info_set_expr(expr, finfo)
#define HeapTupleIsValid(tuple)
Assert(fmt[strlen(fmt) - 1] !='\n')
void get_typlenbyval(Oid typid, int16 *typlen, bool *typbyval)
void getTypeInputInfo(Oid type, Oid *typInput, Oid *typIOParam)
char * get_func_name(Oid funcid)
void pfree(void *pointer)
void * palloc0(Size size)
void * MemoryContextAllocZero(MemoryContext context, Size size)
MemoryContext CurrentMemoryContext
bool MemoryContextContains(MemoryContext context, void *pointer)
MemoryContext MemoryContextGetParent(MemoryContext context)
void MemoryContextDelete(MemoryContext context)
#define AllocSetContextCreate
#define ALLOCSET_DEFAULT_SIZES
#define MemoryContextResetAndDeleteChildren(ctx)
#define CHECK_FOR_INTERRUPTS()
Oid exprType(const Node *expr)
Datum WinGetFuncArgInPartition(WindowObject winobj, int argno, int relpos, int seektype, bool set_mark, bool *isnull, bool *isout)
static void begin_partition(WindowAggState *winstate)
struct WindowObjectData WindowObjectData
static void update_grouptailpos(WindowAggState *winstate)
Datum WinGetFuncArgInFrame(WindowObject winobj, int argno, int relpos, int seektype, bool set_mark, bool *isnull, bool *isout)
WindowAggState * ExecInitWindowAgg(WindowAgg *node, EState *estate, int eflags)
struct WindowStatePerAggData WindowStatePerAggData
static Datum GetAggInitVal(Datum textInitVal, Oid transtype)
static void spool_tuples(WindowAggState *winstate, int64 pos)
static void advance_windowaggregate(WindowAggState *winstate, WindowStatePerFunc perfuncstate, WindowStatePerAgg peraggstate)
static int row_is_in_frame(WindowAggState *winstate, int64 pos, TupleTableSlot *slot)
void ExecEndWindowAgg(WindowAggState *node)
static void eval_windowfunction(WindowAggState *winstate, WindowStatePerFunc perfuncstate, Datum *result, bool *isnull)
struct WindowStatePerFuncData WindowStatePerFuncData
static WindowStatePerAggData * initialize_peragg(WindowAggState *winstate, WindowFunc *wfunc, WindowStatePerAgg peraggstate)
static void finalize_windowaggregate(WindowAggState *winstate, WindowStatePerFunc perfuncstate, WindowStatePerAgg peraggstate, Datum *result, bool *isnull)
static bool advance_windowaggregate_base(WindowAggState *winstate, WindowStatePerFunc perfuncstate, WindowStatePerAgg peraggstate)
static bool window_gettupleslot(WindowObject winobj, int64 pos, TupleTableSlot *slot)
void ExecReScanWindowAgg(WindowAggState *node)
int64 WinGetCurrentPosition(WindowObject winobj)
bool WinRowsArePeers(WindowObject winobj, int64 pos1, int64 pos2)
static TupleTableSlot * ExecWindowAgg(PlanState *pstate)
void WinSetMarkPosition(WindowObject winobj, int64 markpos)
static void eval_windowaggregates(WindowAggState *winstate)
static void release_partition(WindowAggState *winstate)
void * WinGetPartitionLocalMemory(WindowObject winobj, Size sz)
static void update_frametailpos(WindowAggState *winstate)
static void update_frameheadpos(WindowAggState *winstate)
static void initialize_windowaggregate(WindowAggState *winstate, WindowStatePerFunc perfuncstate, WindowStatePerAgg peraggstate)
static bool are_peers(WindowAggState *winstate, TupleTableSlot *slot1, TupleTableSlot *slot2)
Datum WinGetFuncArgCurrent(WindowObject winobj, int argno, bool *isnull)
int64 WinGetPartitionRowCount(WindowObject winobj)
#define castNode(_type_, nodeptr)
#define InvokeFunctionExecuteHook(objectId)
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
void build_aggregate_finalfn_expr(Oid *agg_input_types, int num_finalfn_inputs, Oid agg_state_type, Oid agg_result_type, Oid agg_input_collation, Oid finalfn_oid, Expr **finalfnexpr)
Oid resolve_aggregate_transtype(Oid aggfuncid, Oid aggtranstype, Oid *inputTypes, int numArguments)
void build_aggregate_transfn_expr(Oid *agg_input_types, int agg_num_inputs, int agg_num_direct_inputs, bool agg_variadic, Oid agg_state_type, Oid agg_input_collation, Oid transfn_oid, Oid invtransfn_oid, Expr **transfnexpr, Expr **invtransfnexpr)
bool IsBinaryCoercible(Oid srctype, Oid targettype)
#define FRAMEOPTION_END_CURRENT_ROW
#define FRAMEOPTION_END_OFFSET
#define FRAMEOPTION_EXCLUDE_CURRENT_ROW
#define FRAMEOPTION_END_OFFSET_PRECEDING
#define FRAMEOPTION_START_UNBOUNDED_PRECEDING
#define FRAMEOPTION_START_CURRENT_ROW
#define FRAMEOPTION_START_OFFSET
#define FRAMEOPTION_EXCLUDE_TIES
#define FRAMEOPTION_RANGE
#define FRAMEOPTION_EXCLUDE_GROUP
#define FRAMEOPTION_GROUPS
#define FRAMEOPTION_END_UNBOUNDED_FOLLOWING
#define FRAMEOPTION_START_OFFSET_PRECEDING
#define FRAMEOPTION_EXCLUSION
FormData_pg_aggregate * Form_pg_aggregate
static int list_length(const List *l)
static void * list_nth(const List *list, int n)
FormData_pg_proc * Form_pg_proc
#define DatumGetPointer(X)
#define ObjectIdGetDatum(X)
char * format_procedure(Oid procedure_oid)
MemoryContext ecxt_per_tuple_memory
TupleTableSlot * ecxt_innertuple
TupleTableSlot * ecxt_scantuple
MemoryContext ecxt_per_query_memory
TupleTableSlot * ecxt_outertuple
const TupleTableSlotOps * outerops
ExprContext * ps_ExprContext
ProjectionInfo * ps_ProjInfo
ExecProcNodeMtd ExecProcNode
TupleTableSlot * ss_ScanTupleSlot
TupleDesc tts_tupleDescriptor
MemoryContext partcontext
TupleTableSlot * framehead_slot
FmgrInfo startInRangeFunc
TupleTableSlot * frametail_slot
ExprState * ordEqfunction
TupleTableSlot * temp_slot_2
TupleTableSlot * agg_row_slot
struct WindowObjectData * agg_winobj
WindowStatePerFunc perfunc
MemoryContext curaggcontext
ExprState * partEqfunction
TupleTableSlot * first_part_slot
TupleTableSlot * temp_slot_1
WindowAggState * winstate
WindowFuncExprState * wfuncstate
void ReleaseSysCache(HeapTuple tuple)
HeapTuple SearchSysCache1(int cacheId, Datum key1)
Datum SysCacheGetAttr(int cacheId, HeapTuple tup, AttrNumber attributeNumber, bool *isNull)
bool tuplestore_gettupleslot(Tuplestorestate *state, bool forward, bool copy, TupleTableSlot *slot)
void tuplestore_puttupleslot(Tuplestorestate *state, TupleTableSlot *slot)
void tuplestore_select_read_pointer(Tuplestorestate *state, int ptr)
Tuplestorestate * tuplestore_begin_heap(bool randomAccess, bool interXact, int maxKBytes)
int tuplestore_alloc_read_pointer(Tuplestorestate *state, int eflags)
void tuplestore_trim(Tuplestorestate *state)
bool tuplestore_advance(Tuplestorestate *state, bool forward)
bool tuplestore_in_memory(Tuplestorestate *state)
void tuplestore_end(Tuplestorestate *state)
void tuplestore_set_eflags(Tuplestorestate *state, int eflags)
bool tuplestore_skiptuples(Tuplestorestate *state, int64 ntuples, bool forward)
static TupleTableSlot * ExecClearTuple(TupleTableSlot *slot)
static TupleTableSlot * ExecCopySlot(TupleTableSlot *dstslot, TupleTableSlot *srcslot)
static Datum slot_getattr(TupleTableSlot *slot, int attnum, bool *isnull)
#define WindowObjectIsValid(winobj)
#define WINDOW_SEEK_CURRENT