ds_blockchain_ccas_1.sql

CREATE CHANGELOG eth_txns_priority_fee_analysis AS 
SELECT 
  window_start, 
  window_end, 
  COUNT(*) AS txns_cnt, 
  MIN("maxPriorityFeePerGas") AS min_priority_fee, 
  MAX("maxPriorityFeePerGas") AS max_priority_fee, 
  AVG("maxPriorityFeePerGas") AS avg_priority_fee, 
  STDDEV_SAMP("maxPriorityFeePerGas") AS priority_fee_stddev
FROM HOP(eth_txns_filtered, SIZE 2 MINUTES, ADVANCE BY 15 SECONDS)
GROUP BY window_start, window_end;