Function InitializeGpParallelWorkers

src/backend/executor/execParallel.c:1562–1612

}

bool
InitializeGpParallelWorkers(PlanState *planstate, ParallelWorkerContext *pwcxt)
{
	if (planstate == NULL)
		return false;
	switch (nodeTag(planstate))
	{
		case T_MotionState:
			/*
			 * If we walk to MotionStateNode with Recv Motion Type, we should return directly.
			 * So that we can only Initialize Parallel Entry for current Slice.
			 */
			if (((MotionState *) planstate)->mstype == MOTIONSTATE_RECV)
				return false;
			break;
		case T_SeqScanState:
			if (planstate->plan->parallel_aware)
				ExecSeqScanInitializeWorker((SeqScanState *) planstate, pwcxt);
			break;
		case T_IndexScanState:
			if (planstate->plan->parallel_aware)
				ExecIndexScanInitializeWorker((IndexScanState *) planstate,
											  pwcxt);
			break;
		case T_IndexOnlyScanState:
			if (planstate->plan->parallel_aware)
				ExecIndexOnlyScanInitializeWorker((IndexOnlyScanState *) planstate,
												  pwcxt);
			break;
		case T_BitmapHeapScanState:
			if (planstate->plan->parallel_aware)
				ExecBitmapHeapInitializeWorker((BitmapHeapScanState *) planstate, pwcxt);
			break;
		case T_AppendState:
			if (planstate->plan->parallel_aware)
				ExecAppendInitializeWorker((AppendState *) planstate, pwcxt);
			break;
		case T_HashState:
			break;
		case T_SortState:
			break;
		case T_HashJoinState:
			if (planstate->plan->parallel_aware)
				ExecHashJoinInitializeWorker((HashJoinState *) planstate, pwcxt);
			break;
		default:
			break;
	}

	return planstate_tree_walker(planstate, InitializeGpParallelWorkers, pwcxt);
}

bool
InitializeGpParallelDSMEntry(PlanState *planstate, ParallelContext *pctx)