pg_accumulator
pg_accumulator : Accumulation registers for balance and turnover tracking in PostgreSQL
Overview
| ID | Extension | Package | Version | Category | License | Language |
|---|---|---|---|---|---|---|
| 4845 | pg_accumulator
|
pg_accumulator
|
1.1.3 |
FUNC
|
PostgreSQL
|
C
|
| Attribute | Has Binary | Has Library | Need Load | Has DDL | Relocatable | Trusted |
|---|---|---|---|---|---|---|
--s-d--
|
No
|
Yes
|
No
|
Yes
|
no
|
no
|
| Relationships | |
|---|---|
| Schemas | accum |
| Requires | plpgsql
|
| See Also | financial
topn
quantile
first_last_agg
|
Packages
| Type | Repo | Version | PG Major Compatibility | Package Pattern | Dependencies |
|---|---|---|---|---|---|
| EXT | PIGSTY
|
1.1.3 |
18
17
16
15
14
|
pg_accumulator |
plpgsql |
| RPM | PIGSTY
|
1.1.3 |
18
17
16
15
14
|
pg_accumulator_$v |
- |
| DEB | PIGSTY
|
1.1.3 |
18
17
16
15
14
|
postgresql-$v-pg-accumulator |
- |
| Linux / PG | PG18 | PG17 | PG16 | PG15 | PG14 |
|---|---|---|---|---|---|
el8.x86_64
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
el8.aarch64
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
el9.x86_64
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
el9.aarch64
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
el10.x86_64
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
el10.aarch64
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
d12.x86_64
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
d12.aarch64
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
d13.x86_64
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
d13.aarch64
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
u22.x86_64
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
u22.aarch64
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
u24.x86_64
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
u24.aarch64
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
u26.x86_64
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
u26.aarch64
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
PIGSTY 1.1.3
|
Source
pig build pkg pg_accumulator; # build rpm/debInstall
Make sure PGDG and PIGSTY repo available:
pig repo add pgsql -u # add both repo and update cacheInstall this extension with pig:
pig install pg_accumulator; # install via package name, for the active PG version
pig install pg_accumulator -v 18; # install for PG 18
pig install pg_accumulator -v 17; # install for PG 17
pig install pg_accumulator -v 16; # install for PG 16
pig install pg_accumulator -v 15; # install for PG 15
pig install pg_accumulator -v 14; # install for PG 14Create this extension with:
CREATE EXTENSION pg_accumulator CASCADE; -- requires plpgsqlUsage
Sources: README, documentation, control file
pg_accumulator implements declarative accumulation registers for PostgreSQL. A register records movements across arbitrary dimensions and resources, then exposes generated functions for balances, turnovers, movement history, verification, and rebuild operations.
Enable
CREATE EXTENSION pg_accumulator;For high-write workloads that use the delta buffer and background worker, preload the library and restart PostgreSQL:
shared_preload_libraries = 'pg_accumulator'Create A Register
SELECT accum.register_create(
name := 'inventory',
dimensions := '{"warehouse": "int", "product": "int"}',
resources := '{"quantity": "numeric", "amount": "numeric"}',
kind := 'balance'
);The call creates the register metadata, movement table, total tables, balance cache, triggers, generated query functions, and supporting indexes.
Post And Query Movements
SELECT accum.register_post('inventory', '{
"period": "2026-04-01",
"document": "receipt:1",
"dimensions": {"warehouse": 1, "product": 42},
"resources": {"quantity": 10, "amount": 250}
}');
SELECT * FROM accum.inventory_balance(
dimensions := '{"warehouse": 1, "product": 42}'
);
SELECT * FROM accum.inventory_turnover(
from_date := '2026-04-01',
to_date := '2026-04-30',
dimensions := '{"warehouse": 1}',
group_by := '["product"]'
);Corrections And Maintenance
Use register_unpost and register_repost for retroactive corrections. Use register_verify, register_rebuild_totals, and register_rebuild_cache to check and repair derived state when needed.
SELECT accum.register_unpost('inventory', 'receipt:1');
SELECT accum.register_verify('inventory');Configuration
The documented GUCs include pg_accumulator.background_workers, pg_accumulator.delta_merge_interval, pg_accumulator.delta_merge_delay, pg_accumulator.delta_merge_batch_size, pg_accumulator.partitions_ahead, and pg_accumulator.maintenance_interval.