Updated 2022-11-03
    with staking1 as (
    select
    BLOCK_TIMESTAMP::date as date,
    NODE_ID,
    sum(AMOUNT) as daily_staked
    from flow.core.ez_staking_actions
    where ACTION ='DelegatorTokensCommitted' or ACTION ='TokensCommitted'
    group by 1,2
    ),

    staking2 as (
    select
    BLOCK_TIMESTAMP::date as date,
    NODE_ID,
    sum(AMOUNT) as daily_unstaked
    from flow.core.ez_staking_actions
    where ACTION ='DelegatorRewardTokensWithdrawn' or action ='UnstakedTokensWithdrawn'
    group by 1,2
    ),

    staking_tx1 as (
    select
    a.date,
    a.node_id,
    sum(daily_staked-daily_unstaked) as total_staked
    from staking1 a
    join staking2 b
    on ( a.node_id=b.node_id)
    group by 1,2
    ),

    staking_tx as (
    select
    date,
    NODE_ID as tx_receiver,
    Run a query to Download Data