Spark extension utils for blockchain
Project description
blockchain-spark: Spark extension utils for Web3
How to use
from spark3.transfomer import Transformer
t = Transformer()
df = spark.sql('select * from ethereum.traces limit 100')
df = t.parse_traces_input(df=df, abi='xxxx')
df.show()
from spark3.transfomer import Transformer
t = Transformer()
df = spark.sql('select * from ethereum.logs limit 100')
df = t.parse_logs_data(df=df, abi='xxxx')
df.show()
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
blockchain-spark-0.2.2.tar.gz
(4.9 kB
view hashes)
