Trades Enriched - Allium Documentation Hub

Table Details

Property	Value
Table Name	`robinhood.dex.trades_enriched`
Table Status	Beta 🌱
Unique Key	`block_timestamp`, `unique_id`

Every row of robinhood.dex.trades, with the same columns, plus flags that mark wash and other inorganic trades. Use it when you want DEX volume that reflects real trading, while keeping every trade available.

Nothing is removed. Flagged trades keep their original usd_amount; usd_amount_adjusted is null on them, so you choose what to exclude. Flag details live in robinhood.dex.trades_flagged.

Column	What it adds
`usd_amount_adjusted`	`usd_amount`, or null on flagged trades. Sum it for adjusted volume.
`is_flagged`	`true` if the trade is flagged.
`flag_reason`	Why it is flagged, e.g. `roundtrip_wash`.
`flag_source`	Which key matched: tx hash, tx sender or called contract.
`flagged_at`	Date the flag was added.

Sample Queries

Daily DEX volume, raw and adjusted:

select
    block_timestamp::date as date,
    sum(usd_amount) as volume_usd,
    sum(usd_amount_adjusted) as volume_usd_adjusted,
    sum(usd_amount) - sum(usd_amount_adjusted) as flagged_volume_usd
from robinhood.dex.trades_enriched
where block_timestamp >= current_date - 30
group by 1
order by 1

Only unflagged trades:

select *
from robinhood.dex.trades_enriched
where block_timestamp >= current_date - 1
  and not is_flagged

Always filter on block_timestamp. It keeps queries on this table as fast as on robinhood.dex.trades.

Table Columns

Column Name	Data Type	Description
project	VARCHAR(16777216)	The project (decentralized exchange) of the liquidity pool that the swap occurred from.
protocol	VARCHAR(16777216)	DEX protocol (& version, if applicable) of the contract address facilitating the swap.
liquidity_pool_address	VARCHAR(42)	Contract address of the liquidity pool holding the asset. For protocol without the concept of LP such as airswap, this will be null.
sender_address	VARCHAR(42)	The address of the sender emitted on the swap event logs. This can be a router or pool address.
to_address	VARCHAR(42)	Address of the recipient emitted on the swap event logs. For example, recipient_address from the uniswap v3 swap event log.
token_sold_address	VARCHAR(42)	Token address of the token sold.
token_sold_name	VARCHAR(16777216)	Name of the token sold.
token_sold_symbol	VARCHAR(16777216)	Symbol of the token sold.
token_sold_decimals	NUMBER(38,0)	Token decimals of the token sold.
token_sold_amount_raw_str	VARCHAR(16777216)	Raw amount of tokens sold (unnormalized) in string.
token_sold_amount_raw	FLOAT	Raw amount of tokens sold (unnormalized).
token_sold_amount_str	VARCHAR(16777216)	Amount of tokens sold in string.
token_sold_amount	FLOAT	Amount of tokens sold.
usd_sold_amount	FLOAT	Amount of token sold in USD value.
token_bought_address	VARCHAR(42)	Token address of the token bought, i.e. the asset acquired from the trade.
token_bought_name	VARCHAR(16777216)	Name of the token bought.
token_bought_symbol	VARCHAR(16777216)	Symbol of the token bought.
token_bought_decimals	NUMBER(38,0)	Token decimals of the token bought.
token_bought_amount_raw_str	VARCHAR(16777216)	Raw amount of tokens bought (unnormalized) in string.
token_bought_amount_raw	FLOAT	Raw amount of tokens bought (unnormalized).
token_bought_amount_str	VARCHAR(16777216)	Amount of tokens bought in string.
token_bought_amount	FLOAT	Amount of tokens bought.
usd_bought_amount	FLOAT	Amount of token bought in USD value.
usd_amount	FLOAT	USD value of the swap. This field preferentially selects the USD value of ETH and Stablecoin (USDT/USDC) tokens, as spam token prices may conflate the true swap value.
usd_amount_adjusted	FLOAT	`usd_amount`, or null when `is_flagged` is true. `sum(usd_amount_adjusted)` gives adjusted volume.
is_flagged	BOOLEAN	True if the trade is in `robinhood.dex.trades_flagged`. Filter `where not is_flagged` to exclude flagged trades.
flag_reason	VARCHAR(16777216)	Why the trade is flagged, e.g. `roundtrip_wash`. Null when `is_flagged` is false.
flag_source	VARCHAR(16777216)	Which match key flagged the trade: `transaction_hash`, `transaction_from_address` or `transaction_to_address`. Null when `is_flagged` is false.
flagged_at	DATE	Date the flag was added. Null when `is_flagged` is false.
extra_fields	VARIANT	This field contains all the extra columns emitted from the event/function call that were not part of the convetional DEX trades columns.
swap_count	NUMBER(38,0)	Swap count within the transaction.
transaction_fees	VARCHAR(16777216)	Fees paid at the transaction level. Varchar to retain precision.
transaction_fees_usd	FLOAT	Fees paid in USD.
fee_details	VARIANT	Additional fee details of the transaction, including max priority fee, gas price and gas used for the transaction.
transaction_from_address	VARCHAR(42)	Transaction sender address. I.e. the address of the transaction initiator. (from_address in the raw.transactions field for the transaction_hash of this swap).
transaction_to_address	VARCHAR(42)	Transaction receiver. (to_address in the raw.transactions field for the transaction_hash of this swap).
transaction_hash	VARCHAR(66)	Transaction hash that this swap belongs to.
transaction_index	NUMBER(38,0)	The position of this transaction in the block that it belongs to. The first transaction has index 0.
selector	VARCHAR(16777216)	4byte selector of the transaction.
log_index	NUMBER(38,0)	The position of the swap event log in the transaction.
block_timestamp	TIMESTAMP_NTZ(9)	Block timestamp of the swap event.
block_number	NUMBER(38,0)	Block number of the swap event.
block_hash	VARCHAR(66)	Block hash of the swap event.
unique_id	VARCHAR(16777216)	Unique ID of each trade.
_created_at	TIMESTAMP_NTZ(9)	Timestamp of when the entry was created in the database.
_updated_at	TIMESTAMP_NTZ(9)	Timestamp of when the entry was last updated in the database.
_changed_since_full_refresh	BOOLEAN	Indicates if the record has changed since the last full data refresh.

​Table Details

​Sample Queries

​Table Columns

Table Details

Sample Queries

Table Columns