https://delta.io logo
a

Amit Panwar

05/12/2023, 1:00 PM
Copy code
from delta.tables import *
from pyspark.sql.functions import *
In [11]:
Copy code
deltaTable = DeltaTable.forPath(spark, "tmp/delta-table")
In [12]:
Copy code
# Update every even value by adding 100 to it
deltaTable.update(condition=expr("id % 2 == 0"), set={"id": expr("id + 100")})
i want to run this code locally with pyspark