NotificationsYou must be signed in to change notification settings
Fork6
Star31

Commitab9e0e7

committed

Add shared tuplestores.

SharedTuplestore allows multiple participants to write into it andthen read the tuples back from it in parallel. Each reader receivespartial results.For now it always uses disk files, but other buffering policies andother kinds of scans (ie each reader receives complete results) may beuseful in future.The upcoming parallel hash join feature will use this facility.Author: Thomas MunroReviewed-By: Peter Geoghegan, Andres Freund, Robert HaasDiscussion:https://postgr.es/m/CAEepm=2W=cOkiZxcg6qiFQP-dHUe09aqTrEMM7yJDrHMhDv_RA@mail.gmail.com

1 parent25d5326 commitab9e0e7Copy full SHA for ab9e0e7

File tree

6 files changed

+699

-1

lines changed

src
- backend
  - storage/lmgr
    - lwlock.c
  - utils/sort
    - Makefile
    - sharedtuplestore.c
- include
  - storage
    - lwlock.h
  - utils
    - sharedtuplestore.h
- tools/pgindent
  - typedefs.list

6 files changed

+699

-1

lines changed

`‎src/backend/storage/lmgr/lwlock.c`

Lines changed: 2 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -516,6 +516,8 @@ RegisterLWLockTranches(void)`
`516`	`516`	`"session_record_table");`
`517`	`517`	`LWLockRegisterTranche(LWTRANCHE_SESSION_TYPMOD_TABLE,`
`518`	`518`	`"session_typmod_table");`
	`519`	`+LWLockRegisterTranche(LWTRANCHE_SHARED_TUPLESTORE,`
	`520`	`+"shared_tuplestore");`
`519`	`521`	`LWLockRegisterTranche(LWTRANCHE_TBM,"tbm");`
`520`	`522`	`LWLockRegisterTranche(LWTRANCHE_PARALLEL_APPEND,"parallel_append");`
`521`	`523`

`‎src/backend/utils/sort/Makefile`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -14,7 +14,7 @@ include $(top_builddir)/src/Makefile.global`
`14`	`14`
`15`	`15`	`overrideCPPFLAGS := -I. -I$(srcdir)$(CPPFLAGS)`
`16`	`16`
`17`		`-OBJS = logtape.o sortsupport.o tuplesort.o tuplestore.o`
	`17`	`+OBJS = logtape.osharedtuplestore.osortsupport.o tuplesort.o tuplestore.o`
`18`	`18`
`19`	`19`	`tuplesort.o: qsort_tuple.c`
`20`	`20`

0 commit comments

Comments

(0)

Movatterモバイル変換

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commitab9e0e7

File tree

6 files changed

6 files changed

`‎src/backend/storage/lmgr/lwlock.c`

`‎src/backend/utils/sort/Makefile`

0 commit comments