Danau Delta dengan Spark
# Import Delta Table
from deltalake import DeltaTable
# Read the Delta Table using the Rust API
dt = DeltaTable("../rust/tests/data/simple_table")
# Create a Pandas Dataframe by initially converting the Delta Lake
# table into a PyArrow table
df = dt.to_pyarrow_table().to_pandas()
# Query the Pandas table
Df
# Example output
0 5
1 7
2 9
You can also use Time Travel and load a previous version of the Delta table by specifying the version number by using the load_version method.
# Load version 2 of the table
dt.load_version(2)
Abdalrahman Shlash