Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -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.

Expand Down
4 changes: 2 additions & 2 deletions pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -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"
]
Expand Down
4 changes: 2 additions & 2 deletions src/jsoniq/jars/rumbledb-2.0.0.jar
Git LFS file not shown
6 changes: 0 additions & 6 deletions src/jsoniq/sequence.py
Original file line number Diff line number Diff line change
Expand Up @@ -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

Expand Down