Function ExecInitRuntimeFilter

src/backend/executor/nodeRuntimeFilter.c:145–209

---------------------------------------------------------------- * ExecInitRuntimeFilter * ---------------------------------------------------------------- */

 * ----------------------------------------------------------------
 */
RuntimeFilterState *
ExecInitRuntimeFilter(RuntimeFilter *node, EState *estate, int eflags)
{
	RuntimeFilterState	*rfstate;
	Plan				*outerPlan;

	/*
	 * create state structure
	 */
	rfstate = makeNode(RuntimeFilterState);
	rfstate->ps.plan = (Plan *) node;
	rfstate->ps.state = estate;
	rfstate->ps.ExecProcNode = ExecRuntimeFilter;

	rfstate->build_finish = false;
	rfstate->build_suspend = false;
	rfstate->inner_processed = 0;

	/* will setup later*/
	rfstate->inner_estimated = 0;
	rfstate->inner_threshold = 0;
	rfstate->value_buf = NULL;
	rfstate->raw_value = NULL;
	rfstate->bf = NULL;

	/* CDB: Offer extra info for EXPLAIN ANALYZE. */
	if (estate->es_instrument && (estate->es_instrument & INSTRUMENT_CDB))
	{
		/* Allocate string buffer. */
		rfstate->ps.cdbexplainbuf = makeStringInfo();

		/* Request a callback at end of query. */
		rfstate->ps.cdbexplainfun = ExecRuntimeFilterExplainEnd;
	}

	/*
	 * Miscellaneous initialization
	 *
	 * create expression context for node
	 */
	ExecAssignExprContext(estate, &rfstate->ps);

	/*
	 * initialize outer plan
	 */
	outerPlan = outerPlan(node);
	outerPlanState(rfstate) = ExecInitNode(outerPlan, estate, eflags);

	/*
	 * Initialize result type
	 */
	ExecInitResultTypeTL(&rfstate->ps);

	rfstate->ps.resultopsset = true;
	rfstate->ps.resultops = ExecGetResultSlotOps(outerPlanState(rfstate),
												 &rfstate->ps.resultopsfixed);

	/*