diff --git a/README.md b/README.md index e5b0d89..e39adbb 100644 --- a/README.md +++ b/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. diff --git a/pyproject.toml b/pyproject.toml index 2cb1808..c416703 100644 --- a/pyproject.toml +++ b/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" ] diff --git a/src/jsoniq/jars/rumbledb-2.0.0.jar b/src/jsoniq/jars/rumbledb-2.0.0.jar index 31c0544..fc11788 100644 --- a/src/jsoniq/jars/rumbledb-2.0.0.jar +++ b/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 diff --git a/src/jsoniq/sequence.py b/src/jsoniq/sequence.py index b4844ad..2bb729d 100644 --- a/src/jsoniq/sequence.py +++ b/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