Financial Services

A crypto trading desk monitors Solana DEX activity across Jupiter, Raydium, and Orca. They need to detect whale movements and arbitrage opportunities before the rest of the market reacts — every block (~400ms) matters.

By the time an analyst pulls data from a block explorer, the arbitrage window has closed and the whale has already moved.
LIVEdex_swaps
signatureslotprogramwallettoken_intoken_outamount_inamount_outts
5vGn...kQ3m250847291JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV47xKXa9m2pVEb3R8gT4wNdJfLqYsPnpR4nSOLBONK14.211428572024-03-15T14:32:01.412Z
3kRp...wN8j250847293675kPX9MHTjS2zt1qfr1NYHuzeLXfQM9H24wFSUt1Mp87xKXa9m2pVEb3R8gT4wNdJfLqYsPnpR4nUSDCBONK85006800002024-03-15T14:32:02.204Z
9mTx...bL5e250847295whirLbMiicVdio4qvUfM5KAg6Ct8VwpYzGff3uctyCc7xKXa9m2pVEb3R8gT4wNdJfLqYsPnpR4nSOLBONK6.85371422024-03-15T14:32:03.891Z
2hYd...pK7v250847294JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4Bq4rJ7pVEcSan3k9dTx5NLzRmA8HYfJp2SOLJUP245.518412.52024-03-15T14:32:02.687Z
7fWm...cR2a250847296675kPX9MHTjS2zt1qfr1NYHuzeLXfQM9H24wFSUt1Mp8DxP8rNfvYk4G2mBz5QLr9TJa3nYhR6wKmUSDCWIF42000140002024-03-15T14:32:04.118Z
4nBx...hT9q250847297JUP6LkbZbjS1jKKwapdHNy74zcZ3tLUZoi5QNyVTaV4DxP8rNfvYk4G2mBz5QLr9TJa3nYhR6wKmWIFSOL14000251.32024-03-15T14:32:04.802Z
Streaming SQLRunning
Track whale accumulation patterns
CREATE MATERIALIZED VIEW whale_accumulation AS
SELECT
  wallet,
  token_out AS token,
  SUM(amount_out) AS total_amount,
  COUNT(*) AS swap_count,
  COUNT(DISTINCT program) AS dex_count,
  window_start
FROM TUMBLE(dex_swaps, ts, INTERVAL '30 SECONDS')
GROUP BY wallet, token_out, window_start
HAVING
  SUM(amount_in) > 10000
  OR COUNT(*) > 3;
Detect cross-DEX arbitrage
whale_accumulationauto-updating
wallettokentotal_amountswap_countdex_countwindow_start
7xKX...pR4nBONK2613967432024-03-15T14:32:00.000Z
DxP8...6wKmWIF14000112024-03-15T14:32:00.000Z
Bq4r...Jp2JUP18412.5112024-03-15T14:32:00.000Z
RisingWave detects wallet 7xKX...pR4n accumulating 2.3M BONK across 3 DEXes in 12 seconds. The desk repositions before the price impact fully propagates.
Best-in-Class Event Streaming
for Agents, Apps, and Analytics
GitHubXLinkedInSlackYouTube
Sign up for our to stay updated.