Merge pull request #27 from RumbleDB/Improvements2

Improvements2

Author: ghislainfourny

README.md

@@ -338,7 +338,7 @@ Even more queries can be found [here](https://colab.research.google.com/github/R
 
 # Latest updates
 
-## Version 2.0.6
+## Version 2.0.7
 - Decoupled the internal materialization cap (when a parallel sequence of items is materialized, e.g., into an array) from the outer result size cap (for printing to screen) with now two distinct configuration parameters. The default materialization cap is set to 100'000 items while the default outer result size is set to 10. They can be changed by the user through the Rumble configuration.
 - Fixed an issue in the implementation when a FLWOR gets executed locally with a return clause with an underlying RDD or DataFrame. 
 

pyproject.toml

@@ -4,11 +4,11 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "jsoniq"
-version = "2.0.6"
+version = "2.0.7"
 description = "Python edition of RumbleDB, a JSONiq engine"
 requires-python = ">=3.11"
 dependencies = [
-    "pyspark==4.0",
+    "pyspark==4.0.1",
     "pandas>=2.2",
     "delta-spark==4.0"
 ]

src/jsoniq/jars/rumbledb-2.0.0.jar

@@ -1,3 +1,3 @@
 version https://git-lfs.github.com/spec/v1
-oid sha256:e4fa82699ecbd0f0d9fef9732938f64db8e48d7fc67e93d92942cd399eb14ec6
-size 33138526
+oid sha256:32458322c395d01e3cdd70eeb9509f36fa93d3992cf851737056842f3d134f73
+size 33138507

src/jsoniq/sequence.py

@@ -54,16 +54,10 @@ def rdd(self):
         return self._rumblesession.lastResult
 
     def df(self):
-        if (not "DataFrame" in self._jsequence.availableOutputs()):
-            sys.stderr.write(self.schema_str)
-            return None
         self._rumblesession.lastResult = DataFrame(self._jsequence.getAsDataFrame(), self._sparksession)
         return self._rumblesession.lastResult
 
     def pdf(self):
-        if (not "DataFrame" in self._jsequence.availableOutputs()):
-            sys.stderr.write(self.schema_str)
-            return None
         self._rumblesession.lastResult = self.df().toPandas()
         return self._rumblesession.lastResult