Updated 2023-09-15
    WITH amount_values AS (
    SELECT
    avalanche_tx_amounts.amount / pow(10, ifnull(token_contracts.decimals, 18)) * latest_prices.price AS amount_usd_value
    FROM
    (
    SELECT
    iff(
    input_table.value[0] = '0x0000000000000000000000000000000000000000',
    '0xb31f66aa3c1e785363f0875a1b74e27b85fd66c7',
    input_table.value[0]
    ) as token,
    SUM(input_table.value[1]) as amount
    FROM
    avalanche.core.fact_decoded_event_logs,
    lateral flatten(input => decoded_log['order'] [0]) as input_table
    WHERE
    CONTRACT_ADDRESS IN (
    '0x919df3adbf5cfc9fcfd43198edfe5aa5561cb456',
    '0x6196ac4c950817d23918bb643f4d315ebe0a09b1'
    )
    GROUP BY
    1
    ) as avalanche_tx_amounts
    LEFT JOIN bsc.core.dim_contracts as token_contracts ON avalanche_tx_amounts.token = token_contracts.address
    LEFT JOIN (
    SELECT
    HOUR,
    TOKEN_ADDRESS,
    PRICE
    FROM
    (
    SELECT
    HOUR,
    TOKEN_ADDRESS,
    price,
    ROW_NUMBER() OVER (
    Run a query to Download Data