Last updated:
0 purchases
blockchainspark 0.2.2
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()
For personal and professional use. You cannot resell or redistribute these repositories in their original state.
There are no reviews.