datavortexinflow outflow
    Updated 2025-03-21
    WITH petra_wallets AS (
    SELECT DISTINCT owner_address
    FROM aptos.core.dim_aptos_names
    WHERE domain ILIKE 'petra'
    )
    SELECT
    ft.account_address,
    SUM(CASE WHEN ft.transfer_event = 'DepositEvent' THEN ft.amount ELSE 0 END) AS inflow_amount,
    SUM(CASE WHEN ft.transfer_event = 'WithdrawEvent' THEN -ft.amount ELSE 0 END) AS outflow_amount,
    SUM(CASE
    WHEN ft.transfer_event = 'DepositEvent' THEN ft.amount
    WHEN ft.transfer_event = 'WithdrawEvent' THEN -ft.amount
    ELSE 0
    END) AS netflow_amount,
    ft.token_address
    FROM
    aptos.core.fact_transfers ft
    JOIN
    petra_wallets pw
    ON
    ft.account_address = pw.owner_address
    WHERE
    ft.transfer_event IN ('DepositEvent', 'WithdrawEvent')
    GROUP BY
    ft.account_address, ft.token_address;

    QueryRunArchived: QueryRun has been archived