Identity Aggregates
Pre-aggregated rollups of labeled activity — balances and flows grouped by entity, category or attributed country. These sit on top ofaddress_labels, so anything not attributed
by the labeling pipeline is not represented here.
All tables live in the
allium_identity.aggregates schema.Table Overview
Each table’s grain is listed in its section below.
Balance tables carry
usd_balance computed at snapshot time. Tokens without
price coverage have a null usd_balance while balance is still populated, so
filter on usd_balance IS NOT NULL when summing USD.Entity Wallet Registry
allium_identity.aggregates.entity_wallet_registry
Registry mapping anonymized wallet IDs to their attributed entity, category, and attribution metadata. Used as the join key between entity_balances_daily and real address data.
Grain: one row per (wallet_id, primary_entity)
CEX Deposits and Withdrawals
allium_identity.aggregates.cex_deposits_withdrawals
Daily aggregated deposit and withdrawal volumes per entity, chain, and token. Captures deposits (amount_in) and withdrawals (amount_out) between entity wallets and CEX addresses.
Grain: one row per (date, entity, chain, token_address)
CEX Attributed Flows
allium_identity.aggregates.cex_attributed_flows
Cross-entity flow aggregates attributed to centralized exchanges. Each row captures a directional flow between two entities (from_entity → to_entity) for a given chain, token, and date, with category and grain classification on both sides.
Grain: one row per (date, chain, from_key, to_key, token_address)
Entity Balances Daily
allium_identity.aggregates.entity_balances_daily
Daily stablecoin and native token balance snapshots for attributed entity wallets over a rolling window. Uses anonymized wallet IDs to protect IP while preserving attributional structure.
Grain: one row per (date, entity, chain, token_address)
Category Balances Daily
allium_identity.aggregates.category_balances_daily
Daily stablecoin and native token balance snapshots rolled up to entity category grain (CEX, DEX, bridge, lending, etc.). Sums all entity-level balances within each principal_category. One row per (date, category, chain, token_address).
Grain: one row per (date, category, chain, token_address)
Geo Balances Daily
allium_identity.aggregates.geo_balances_daily
Daily balance snapshots for wallets with geographic attribution, broken down by primary country and region. Extends entity_balances_daily with geo signals.
Grain: one row per (date, primary_country, chain, token_address)
Geo Balances with Exchanges Added Daily
allium_identity.aggregates.geo_balances_exchanges_added_daily
Daily balance snapshots for exchange-attributed wallets with geographic classification. Extends geo_balances_daily with exchange-depositor address additions.
Grain: one row per (date, primary_country, chain, token_address)
Stablecoin Top Holders
allium_identity.aggregates.stablecoin_top_holders
Top stablecoin holders ranked by balance, by chain and token symbol. Includes both chain-scoped and global cross-chain rankings.
Grain: one row per (chain, primary_entity, token_address)