File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 11version https://git-lfs.github.com/spec/v1
2- oid sha256:6e55a44233af9e937db13f5db036521860a74f4396b88c1a82d085f1b6933ef0
3- size 33054930
2+ oid sha256:f559c7bc57eb22ba5257a6ba6c79d3fd4cebd89f5cebe6dba0bca0ff68f724e3
3+ size 33207084
Original file line number Diff line number Diff line change @@ -54,10 +54,16 @@ def rdd(self):
5454 return self ._rumblesession .lastResult
5555
5656 def df (self ):
57+ if (not "DataFrame" in self ._jsequence .availableOutputs ()):
58+ sys .stderr .write (self .schema_str )
59+ return None
5760 self ._rumblesession .lastResult = DataFrame (self ._jsequence .getAsDataFrame (), self ._sparksession )
5861 return self ._rumblesession .lastResult
5962
6063 def pdf (self ):
64+ if (not "DataFrame" in self ._jsequence .availableOutputs ()):
65+ sys .stderr .write (self .schema_str )
66+ return None
6167 self ._rumblesession .lastResult = self .df ().toPandas ()
6268 return self ._rumblesession .lastResult
6369
You can’t perform that action at this time.
0 commit comments