Transforming blockchain data with Streaming SQL
name
: A shortname for this transform
You can refer to this from sinks via from
or treat it as a table in SQL from other transforms.
sql
: The actual SQL
To filter your data, use a WHERE
clause, e.g. WHERE liquidity > 1000
.
To map your data, use an AS
clause combined with SELECT
, e.g. SELECT wei / 1000000000 AS gwei
.
primary_key
: A unique ID
This should be unique, but you can also use this to intentionally de-duplicate data - the latest row with the same ID will replace all the others.