CarlOwOsUSDC flow
    Updated 2022-06-16
    WITH usdc_transfer_in AS (
    SELECT tx_to
    , SUM(amount) AS transfer_in
    FROM solana.core.fact_transfers
    WHERE block_timestamp >= CURRENT_DATE - 60
    AND mint = 'EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v'
    GROUP BY tx_to
    ),
    usdc_transfer_out AS (
    SELECT tx_from
    , SUM(amount) AS transfer_out
    FROM solana.core.fact_transfers
    WHERE block_timestamp >= CURRENT_DATE - 60
    AND mint = 'EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v'
    GROUP BY tx_from
    ),
    usdc_swap_in AS (
    SELECT swapper
    , SUM(swap_to_amount) as swap_in
    FROM solana.core.fact_swaps
    WHERE block_timestamp >= CURRENT_DATE - 60
    AND swap_to_mint = 'EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v'
    GROUP BY swapper
    ),
    usdc_swap_out AS (
    SELECT swapper
    , SUM(swap_from_amount) as swap_out
    FROM solana.core.fact_swaps
    WHERE block_timestamp >= CURRENT_DATE - 60
    AND swap_from_mint = 'EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v'
    GROUP BY swapper
    )
    SELECT CASE WHEN tx_to IS NULL THEN CASE WHEN tx_from IS NULL THEN CASE WHEN i.swapper IS NULL THEN o.swapper ELSE i.swapper END ELSE tx_from END ELSE tx_to END as wallet
    , transfer_in+swap_in-transfer_out-swap_out AS net_usdc_flow
    , row_number() over (order by net_usdc_flow desc) as rank
    FROM usdc_transfer_in
    Run a query to Download Data