Add withDelta() and fix config()

Improvements

Author: ghislainfourny

README.md

@@ -349,6 +349,10 @@ Even more queries can be found [here](https://colab.research.google.com/github/R
 
 # Latest updates
 
+## Version 0.2.0 alpha 6
+- Fix a bug with the config() call of the builder.
+- add withDelta() to configure Delta Lake tables and files, for use with the JSONiq Update Facility.
+
 ## Version 0.2.0 alpha 5
 - If the initialization of the Spark session fails, we now check if SPARK_HOME is set and if it may be invalid or pointing to a different Spark version than 4.0, and output a more informative error message. 
 

pyproject.toml

@@ -4,12 +4,13 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "jsoniq"
-version = "0.2.0a5"
+version = "0.2.0a6"
 description = "Python edition of RumbleDB, a JSONiq engine"
 requires-python = ">=3.11"
 dependencies = [
     "pyspark==4.0",
-    "pandas>=2.2"
+    "pandas>=2.2",
+    "delta-spark==4.0"
 ]
 authors = [
   {name = "Ghislain Fourny", email = "ghislain.fourny@inf.ethz.ch"},

src/jsoniq/jars/rumbledb-1.24.0.jar

@@ -111,12 +111,15 @@ def master(self, url):
             self._sparkbuilder = self._sparkbuilder.master(url);
             return self;
 
-        def config(self, key, value):
-            self._sparkbuilder = self._sparkbuilder.config(key, value);   
+        def config(self, key=None, value=None, conf=None, *, map=None):
+            self._sparkbuilder = self._sparkbuilder.config(key=key, value=value, conf=conf, map=map)
             return self;
 
-        def config(self, conf):
-            self._sparkbuilder = self._sparkbuilder.config(conf);   
+        def withDelta(self):
+            self._sparkbuilder = self._sparkbuilder \
+                .config("spark.sql.extensions", "io.delta.sql.DeltaSparkSessionExtension") \
+                .config("spark.sql.catalog.spark_catalog", "org.apache.spark.sql.delta.catalog.DeltaCatalog") \
+                .config("spark.jars.packages", "io.delta:delta-spark_2.13:4.0.0")
             return self;
 
         def __getattr__(self, name):