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:e4fa82699ecbd0f0d9fef9732938f64db8e48d7fc67e93d92942cd399eb14ec6
3- size 33138526
2+ oid sha256:32458322c395d01e3cdd70eeb9509f36fa93d3992cf851737056842f3d134f73
3+ size 33138507
Original file line number Diff line number Diff line change @@ -54,16 +54,10 @@ 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
6057 self ._rumblesession .lastResult = DataFrame (self ._jsequence .getAsDataFrame (), self ._sparksession )
6158 return self ._rumblesession .lastResult
6259
6360 def pdf (self ):
64- if (not "DataFrame" in self ._jsequence .availableOutputs ()):
65- sys .stderr .write (self .schema_str )
66- return None
6761 self ._rumblesession .lastResult = self .df ().toPandas ()
6862 return self ._rumblesession .lastResult
6963
You can’t perform that action at this time.
0 commit comments