Skip to content

Commit 60a01e3

Browse files
author
Ghislain Fourny
committed
Fix issue with JSON RDD
1 parent 1a25c29 commit 60a01e3

2 files changed

Lines changed: 1 addition & 4 deletions

File tree

154 KB
Binary file not shown.

src/jsoniq/sequence.py

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -11,10 +11,7 @@ def getAsJSONList(self):
1111
return [json.loads(l.serializeAsJSON()) for l in self._jsequence.getAsList()]
1212

1313
def getAsJSONRDD(self):
14-
rdd = self._jsequence.getAsStringRDD();
15-
print("Strings:");
16-
for s in rdd.take(10):
17-
print(s);
14+
rdd = self._jsequence.getAsPickledStringRDD();
1815
rdd = RDD(rdd, self._sparkcontext)
1916
return rdd.map(lambda l: json.loads(l))
2017

0 commit comments

Comments
 (0)