Use callback instead of calling ExecFilterJunk()

1. Added ExecFilterJunkFunc function pointer to JunkFilter struct;
2. Replaced ExecFilterJunk() with function pointer calls;
3. Initialized function pointer in ExecInitJunkFilter() and
   ExecInitJunkFilterConversion();
4. Updated all ExecFilterJunk() calls to use the function pointer;

This change makes JunkFilter's filtering behavior more extensible
and customizable while maintaining existing functionality.

Author: zhangyue-hashdata

src/backend/executor/execExpr.c

@@ -2927,7 +2927,8 @@ ExecInitWholeRowVar(ExprEvalStep *scratch, Var *variable, ExprState *state)
 				scratch->d.wholerow.junkFilter =
 					ExecInitJunkFilter(subplan->plan->targetlist,
 									   ExecInitExtraTupleSlot(parent->state, NULL,
-															  &TTSOpsVirtual));
+															  &TTSOpsVirtual),
+									   ExecFilterJunk);
 			}
 		}
 	}

src/backend/executor/execExprInterp.c

@@ -4205,7 +4205,10 @@ ExecEvalWholeRowVar(ExprState *state, ExprEvalStep *op, ExprContext *econtext)
 
 	/* Apply the junkfilter if any */
 	if (op->d.wholerow.junkFilter != NULL)
-		slot = ExecFilterJunk(op->d.wholerow.junkFilter, slot);
+	{
+		JunkFilter *junkfilter = op->d.wholerow.junkFilter;
+		slot = junkfilter->jf_execFilterJunkFunc(junkfilter, slot);
+	}
 
 	/*
 	 * If first time through, obtain tuple descriptor and check compatibility.

src/backend/executor/execJunk.c

@@ -55,9 +55,11 @@
  * The source targetlist is passed in.  The output tuple descriptor is
  * built from the non-junk tlist entries.
  * An optional resultSlot can be passed as well; otherwise, we create one.
+ * An optional execFilterJunkFunc can be passed as well; otherwise, we use ExecFilterJunk.
  */
 JunkFilter *
-ExecInitJunkFilter(List *targetList, TupleTableSlot *slot)
+ExecInitJunkFilter(List *targetList, TupleTableSlot *slot,
+				   ExecFilterJunkFunc execFilterJunkFunc)
 {
 	JunkFilter *junkfilter;
 	TupleDesc	cleanTupType;
@@ -119,6 +121,8 @@ ExecInitJunkFilter(List *targetList, TupleTableSlot *slot)
 	junkfilter->jf_cleanTupType = cleanTupType;
 	junkfilter->jf_cleanMap = cleanMap;
 	junkfilter->jf_resultSlot = slot;
+	junkfilter->jf_execFilterJunkFunc =
+		execFilterJunkFunc ? execFilterJunkFunc : ExecFilterJunk;
 
 	return junkfilter;
 }
@@ -136,7 +140,8 @@ ExecInitJunkFilter(List *targetList, TupleTableSlot *slot)
 JunkFilter *
 ExecInitJunkFilterConversion(List *targetList,
 							 TupleDesc cleanTupType,
-							 TupleTableSlot *slot)
+							 TupleTableSlot *slot,
+							 ExecFilterJunkFunc execFilterJunkFunc)
 {
 	JunkFilter *junkfilter;
 	int			cleanLength;
@@ -196,6 +201,8 @@ ExecInitJunkFilterConversion(List *targetList,
 	junkfilter->jf_cleanTupType = cleanTupType;
 	junkfilter->jf_cleanMap = cleanMap;
 	junkfilter->jf_resultSlot = slot;
+	junkfilter->jf_execFilterJunkFunc =
+		execFilterJunkFunc ? execFilterJunkFunc : ExecFilterJunk;
 
 	return junkfilter;
 }

src/backend/executor/execMain.c

@@ -2035,7 +2035,8 @@ InitPlan(QueryDesc *queryDesc, int eflags)
 
 			slot = ExecInitExtraTupleSlot(estate, NULL, &TTSOpsVirtual);
 			j = ExecInitJunkFilter(planstate->plan->targetlist,
-								   slot);
+								   slot,
+								   ExecFilterJunk);
 			estate->es_junkFilter = j;
 
 			/* Want to return the cleaned tuple type */
@@ -2805,7 +2806,7 @@ ExecutePlan(EState *estate,
 		 * because that tuple slot has the wrong descriptor.)
 		 */
 		if (estate->es_junkFilter != NULL)
-			slot = ExecFilterJunk(estate->es_junkFilter, slot);
+			slot = estate->es_junkFilter->jf_execFilterJunkFunc(estate->es_junkFilter, slot);
 
 		if (operation != CMD_SELECT && Gp_role == GP_ROLE_EXECUTE && !Gp_is_writer)
 		{

src/backend/executor/functions.c

@@ -895,9 +895,10 @@ init_sql_fcache(FunctionCallInfo fcinfo, Oid collation, bool lazyEvalOK)
 		if (rettupdesc && fcache->returnsTuple)
 			fcache->junkFilter = ExecInitJunkFilterConversion(resulttlist,
 															  rettupdesc,
-															  slot);
+															  slot,
+															  ExecFilterJunk);
 		else
-			fcache->junkFilter = ExecInitJunkFilter(resulttlist, slot);
+			fcache->junkFilter = ExecInitJunkFilter(resulttlist, slot, ExecFilterJunk);
 	}
 
 	if (fcache->returnsTuple)
@@ -2225,7 +2226,7 @@ sqlfunction_receive(TupleTableSlot *slot, DestReceiver *self)
 	DR_sqlfunction *myState = (DR_sqlfunction *) self;
 
 	/* Filter tuple as needed */
-	slot = ExecFilterJunk(myState->filter, slot);
+	slot = myState->filter->jf_execFilterJunkFunc(myState->filter, slot);
 
 	/* Store the filtered tuple into the tuplestore */
 	tuplestore_puttupleslot(myState->tstore, slot);

src/backend/executor/nodeTableFunction.c

@@ -395,7 +395,8 @@ ExecInitTableFunction(TableFunctionScan *node, EState *estate, int eflags)
 	/* Determine projection information for subplan */
 	scanstate->inputscan->junkfilter =
 		ExecInitJunkFilter(subplan->plan->targetlist, 
-						   NULL  /* slot */);
+						   NULL  /* slot */,
+						   ExecFilterJunk);
 	BlessTupleDesc(scanstate->inputscan->junkfilter->jf_cleanTupType);
 
 	/*
@@ -524,7 +525,7 @@ AnyTable_GetNextTuple(AnyTable t)
 	 * ----------------------------------------
 	 */
 
-	slot = ExecFilterJunk(t->junkfilter, t->econtext->ecxt_outertuple);
+	slot = t->junkfilter->jf_execFilterJunkFunc(t->junkfilter, t->econtext->ecxt_outertuple);
 	return ExecCopySlotHeapTuple(slot);
 }
 

src/include/executor/executor.h

@@ -175,10 +175,12 @@ extern void ResetTupleHashTable(TupleHashTable hashtable);
  * prototypes from functions in execJunk.c
  */
 extern JunkFilter *ExecInitJunkFilter(List *targetList,
-									  TupleTableSlot *slot);
+									  TupleTableSlot *slot,
+									  ExecFilterJunkFunc execFilterJunkFunc);
 extern JunkFilter *ExecInitJunkFilterConversion(List *targetList,
 												TupleDesc cleanTupType,
-												TupleTableSlot *slot);
+												TupleTableSlot *slot,
+												ExecFilterJunkFunc execFilterJunkFunc);
 extern AttrNumber ExecFindJunkAttribute(JunkFilter *junkfilter,
 										const char *attrName);
 extern AttrNumber ExecFindJunkAttributeInTlist(List *targetlist,

src/include/nodes/execnodes.h

@@ -374,15 +374,21 @@ typedef struct ProjectionInfo
  *						attribute numbers of the "original" tuple and the
  *						attribute numbers of the "clean" tuple.
  *	  resultSlot:		tuple slot used to hold cleaned tuple.
+ *	  execFilterJunk:	function pointer to the function that will be used
+ *						to filter the junk attributes from the input tuple.
  * ----------------
  */
+typedef struct JunkFilter JunkFilter;
+typedef TupleTableSlot* (*ExecFilterJunkFunc)(JunkFilter *junkfilter,
+											  TupleTableSlot *slot);
 typedef struct JunkFilter
 {
 	NodeTag		type;
 	List	   *jf_targetList;
 	TupleDesc	jf_cleanTupType;
 	AttrNumber *jf_cleanMap;
 	TupleTableSlot *jf_resultSlot;
+	ExecFilterJunkFunc jf_execFilterJunkFunc;
 } JunkFilter;
 
 /*