Amit Panwar
05/12/2023, 12:07 PMTristen
05/12/2023, 12:21 PMCarl Mattsson
05/12/2023, 12:34 PMAmit Panwar
05/12/2023, 1:00 PMfrom delta.tables import *
from pyspark.sql.functions import *
In [11]:
deltaTable = DeltaTable.forPath(spark, "tmp/delta-table")
In [12]:
# Update every even value by adding 100 to it
deltaTable.update(condition=expr("id % 2 == 0"), set={"id": expr("id + 100")})
deltaTable.update
this is not working