Movatterモバイル変換

Skip to content

postgrespro/postgresPublic

forked frompostgres/postgres

NotificationsYou must be signed in to change notification settings
Fork6
Star31

Commit5262f7a

robertmhaas

committed

Add optimizer and executor support for parallel index scans.

In combination with569174f, whichtaught the btree AM how to perform parallel index scans, this allowsparallel index scan plans on btree indexes. This infrastructureshould be general enough to support parallel index scans for otherindex AMs as well, if someone updates them to support parallelscans.Amit Kapila, reviewed and tested by Anastasia Lubennikova, TusharAhuja, and Haribabu Kommi, and me.

1 parent51ee6f3 commit5262f7aCopy full SHA for 5262f7a

File tree

29 files changed

+366

-55

lines changed

contrib/bloom
doc/src/sgml
- indexam.sgml
src
- backend
  - access
    - brin
      - brin.c
    - gin
      - ginutil.c
    - gist
      - gist.c
    - hash
      - hash.c
    - nbtree
      - nbtree.c
    - spgist
      - spgutils.c
  - executor
    - execParallel.c
    - nodeIndexscan.c
  - optimizer
    - path
    - plan
      - planner.c
    - util
      - pathnode.c
      - plancat.c
  - utils/adt
    - selfuncs.c
- include
  - access
    - amapi.h
  - executor
    - nodeIndexscan.h
  - nodes
    - execnodes.h
    - relation.h
  - optimizer
  - utils
    - index_selfuncs.h
- test/regress
  - expected
    - select_parallel.out
  - sql
    - select_parallel.sql

29 files changed

+366

-55

lines changed

`‎contrib/bloom/blcost.c‎`

Lines changed: 3 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -24,7 +24,8 @@`
`24`	`24`	`void`
`25`	`25`	`blcostestimate(PlannerInforoot,IndexPathpath,doubleloop_count,`
`26`	`26`	`CostindexStartupCost,CostindexTotalCost,`
`27`		`-SelectivityindexSelectivity,doubleindexCorrelation)`
	`27`	`+SelectivityindexSelectivity,doubleindexCorrelation,`
	`28`	`+double*indexPages)`
`28`	`29`	`{`
`29`	`30`	`IndexOptInfo*index=path->indexinfo;`
`30`	`31`	`List*qinfos;`
`@@ -45,4 +46,5 @@ blcostestimate(PlannerInfo root, IndexPath path, double loop_count,`
`45`	`46`	`*indexTotalCost=costs.indexTotalCost;`
`46`	`47`	`*indexSelectivity=costs.indexSelectivity;`
`47`	`48`	`*indexCorrelation=costs.indexCorrelation;`
	`49`	`+*indexPages=costs.numIndexPages;`
`48`	`50`	`}`

`‎contrib/bloom/bloom.h‎`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -208,6 +208,6 @@ extern bytea *bloptions(Datum reloptions, bool validate);`
`208`	`208`	`externvoidblcostestimate(PlannerInforoot,IndexPathpath,`
`209`	`209`	`doubleloop_count,Cost*indexStartupCost,`
`210`	`210`	`CostindexTotalCost,SelectivityindexSelectivity,`
`211`		`-double*indexCorrelation);`
	`211`	`+doubleindexCorrelation,doubleindexPages);`
`212`	`212`
`213`	`213`	`#endif`

`‎contrib/bloom/blutils.c‎`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -119,6 +119,7 @@ blhandler(PG_FUNCTION_ARGS)`
`119`	`119`	`amroutine->amstorage= false;`
`120`	`120`	`amroutine->amclusterable= false;`
`121`	`121`	`amroutine->ampredlocks= false;`
	`122`	`+amroutine->amcanparallel= false;`
`122`	`123`	`amroutine->amkeytype=InvalidOid;`
`123`	`124`
`124`	`125`	`amroutine->ambuild=blbuild;`

`‎doc/src/sgml/indexam.sgml‎`

Lines changed: 2 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -110,6 +110,8 @@ typedef struct IndexAmRoutine`
`110`	`110`	`bool amclusterable;`
`111`	`111`	`/* does AM handle predicate locks? */`
`112`	`112`	`bool ampredlocks;`
	`113`	`+ /* does AM support parallel scan? */`
	`114`	`+ bool amcanparallel;`
`113`	`115`	`/* type of data stored in index, or InvalidOid if variable */`
`114`	`116`	`Oid amkeytype;`
`115`	`117`

`‎src/backend/access/brin/brin.c‎`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -93,6 +93,7 @@ brinhandler(PG_FUNCTION_ARGS)`
`93`	`93`	`amroutine->amstorage= true;`
`94`	`94`	`amroutine->amclusterable= false;`
`95`	`95`	`amroutine->ampredlocks= false;`
	`96`	`+amroutine->amcanparallel= false;`
`96`	`97`	`amroutine->amkeytype=InvalidOid;`
`97`	`98`
`98`	`99`	`amroutine->ambuild=brinbuild;`

`‎src/backend/access/gin/ginutil.c‎`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -50,6 +50,7 @@ ginhandler(PG_FUNCTION_ARGS)`
`50`	`50`	`amroutine->amstorage= true;`
`51`	`51`	`amroutine->amclusterable= false;`
`52`	`52`	`amroutine->ampredlocks= false;`
	`53`	`+amroutine->amcanparallel= false;`
`53`	`54`	`amroutine->amkeytype=InvalidOid;`
`54`	`55`
`55`	`56`	`amroutine->ambuild=ginbuild;`

`‎src/backend/access/gist/gist.c‎`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -71,6 +71,7 @@ gisthandler(PG_FUNCTION_ARGS)`
`71`	`71`	`amroutine->amstorage= true;`
`72`	`72`	`amroutine->amclusterable= true;`
`73`	`73`	`amroutine->ampredlocks= false;`
	`74`	`+amroutine->amcanparallel= false;`
`74`	`75`	`amroutine->amkeytype=InvalidOid;`
`75`	`76`
`76`	`77`	`amroutine->ambuild=gistbuild;`

`‎src/backend/access/hash/hash.c‎`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -67,6 +67,7 @@ hashhandler(PG_FUNCTION_ARGS)`
`67`	`67`	`amroutine->amstorage= false;`
`68`	`68`	`amroutine->amclusterable= false;`
`69`	`69`	`amroutine->ampredlocks= false;`
	`70`	`+amroutine->amcanparallel= false;`
`70`	`71`	`amroutine->amkeytype=INT4OID;`
`71`	`72`
`72`	`73`	`amroutine->ambuild=hashbuild;`

`‎src/backend/access/nbtree/nbtree.c‎`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -140,6 +140,7 @@ bthandler(PG_FUNCTION_ARGS)`
`140`	`140`	`amroutine->amstorage= false;`
`141`	`141`	`amroutine->amclusterable= true;`
`142`	`142`	`amroutine->ampredlocks= true;`
	`143`	`+amroutine->amcanparallel= true;`
`143`	`144`	`amroutine->amkeytype=InvalidOid;`
`144`	`145`
`145`	`146`	`amroutine->ambuild=btbuild;`

`‎src/backend/access/spgist/spgutils.c‎`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -49,6 +49,7 @@ spghandler(PG_FUNCTION_ARGS)`
`49`	`49`	`amroutine->amstorage= false;`
`50`	`50`	`amroutine->amclusterable= false;`
`51`	`51`	`amroutine->ampredlocks= false;`
	`52`	`+amroutine->amcanparallel= false;`
`52`	`53`	`amroutine->amkeytype=InvalidOid;`
`53`	`54`
`54`	`55`	`amroutine->ambuild=spgbuild;`

0 commit comments

Comments

(0)

[8]ページ先頭

©2009-2025 Movatter.jp