Commit0810e1f

committed

Add GUC on distributed execution paths

1 parent97c3440 commit0810e1fCopy full SHA for 0810e1f

File tree

+14

-7

lines changed

+14

-7

lines changed

Lines changed: 2 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -39,7 +39,8 @@ HOOK_Baserel_paths(PlannerInfo root, RelOptInfo rel, Index rti,`
`39`	`39`	`if (prev_set_rel_pathlist_hook)`
`40`	`40`	`(*prev_set_rel_pathlist_hook) (root,rel,rti,rte);`
`41`	`41`
`42`		`-add_exchange_paths(root,rel,rti,rte);`
	`42`	`+if (enable_distributed_execution)`
	`43`	`+add_exchange_paths(root,rel,rti,rte);`
`43`	`44`	`}`
`44`	`45`
`45`	`46`	`staticbool`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -44,7 +44,7 @@ static CustomScanMethodsdistplanexec_plan_methods;`
`44`	`44`	`staticCustomExecMethodsdistplanexec_exec_methods;`
`45`	`45`
`46`	`46`	`chardestsName[10]="DMQ_DESTS";`
`47`		`-char*network_interface;`
	`47`	`+boolenable_distributed_execution;`
`48`	`48`
`49`	`49`
`50`	`50`	`staticNodeCreateDistPlanExecState(CustomScannode);`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -27,7 +27,7 @@ typedef struct`
`27`	`27`	`}lcontext;`
`28`	`28`
`29`	`29`
`30`		`-externchar*network_interface;`
	`30`	`+externboolenable_distributed_execution;`
`31`	`31`	`externchardestsName[10];`
`32`	`32`	`#defineDISTEXECPATHNAME"DistExecPath"`
`33`	`33`

Lines changed: 10 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -69,10 +69,16 @@ shmem_size(void)`
`69`	`69`	`void`
`70`	`70`	`_PG_init(void)`
`71`	`71`	`{`
`72`		`-DefineCustomStringVariable("network_interface",`
`73`		`-"Set network interface for EXCHANGE communications",`
`74`		`-NULL,&network_interface,"lo",`
`75`		`-PGC_SUSET,GUC_NOT_IN_SAMPLE,NULL,NULL,NULL);`
	`72`	`+DefineCustomBoolVariable("enable_distributed_execution",`
	`73`	`+"Use distributed execution.",`
	`74`	`+NULL,`
	`75`	`+&enable_distributed_execution,`
	`76`	`+ true,`
	`77`	`+PGC_USERSET,`
	`78`	`+GUC_NOT_IN_SAMPLE,`
	`79`	`+NULL,`
	`80`	`+NULL,`
	`81`	`+NULL);`
`76`	`82`
`77`	`83`	`EXCHANGE_Init_methods();`
`78`	`84`	`DUMMYSCAN_Init_methods();`

Comments

(0)