Parquet

It is quite simple to read a parquet file using the read_parquet() function.

from datafusion import SessionContext

ctx = SessionContext()
df = ctx.read_parquet("file.parquet")

An alternative is to use register_parquet()

ctx.register_parquet("file", "file.parquet")
df = ctx.table("file")

previous

JSON

next

Custom Table Provider