Function ExecInitRuntimeFilterFinish

src/backend/executor/nodeRuntimeFilter.c:229–263

}

void
ExecInitRuntimeFilterFinish(RuntimeFilterState *node, double inner_rows)
{
	List	   *hashops;
	ListCell   *lc;
	int			i = 0;

	hashops = node->hjstate->hj_HashOperators;

	node->value_buf = (Datum *) palloc(hashops->length * sizeof(Datum));
	node->raw_value = (bool *) palloc(hashops->length * sizeof(bool));
	node->inner_estimated = (uint64) inner_rows;

	node->bf = bloom_create_aggresive((int64) inner_rows, work_mem, random());
	if (node->bf == NULL)
		node->build_suspend = true;
	/* we can't handle inner table which is bigger than this threshold */
	node->inner_threshold = bloom_total_bits(node->bf) / 1.6;

	/* init hash function related fields */
	foreach(lc, hashops)
	{
		Oid outer_typ;
		Oid inner_typ;
		bool outer_raw;
		bool inner_raw;

		op_input_types(lfirst_oid(lc), &outer_typ, &inner_typ);
		outer_raw = IsRawInt8CmpType(outer_typ);
		inner_raw = IsRawInt8CmpType(inner_typ);

		/* can we directly compare the i-th value as int8? */
		node->raw_value[i++] = outer_raw && inner_raw;
	}
}

void
ExecEndRuntimeFilter(RuntimeFilterState *node)