Skip to main content

Identity Aggregates

Pre-aggregated rollups of labeled activity — balances and flows grouped by entity, category or attributed country. These sit on top of address_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)