Skip to content

Commit ac1d4c0

Browse files
committed
Bug fix.
1 parent b163365 commit ac1d4c0

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

python/pyspark/sql/context.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -185,7 +185,7 @@ def _inferSchema(self, rdd, samplingRatio=None):
185185
return schema
186186

187187
def inferSchema(self, rdd, samplingRatio=None):
188-
"""::note: Deprecated in 1.3, use :func:`createDataFrame` instead
188+
"""::note: Deprecated in 1.3, use :func:`createDataFrame` instead.
189189
"""
190190
warnings.warn("inferSchema is deprecated, please use createDataFrame instead")
191191

@@ -195,7 +195,7 @@ def inferSchema(self, rdd, samplingRatio=None):
195195
return self.createDataFrame(rdd, None, samplingRatio)
196196

197197
def applySchema(self, rdd, schema):
198-
"""::note: Deprecated in 1.3, use :func:`createDataFrame` instead
198+
"""::note: Deprecated in 1.3, use :func:`createDataFrame` instead.
199199
"""
200200
warnings.warn("applySchema is deprecated, please use createDataFrame instead")
201201

@@ -315,7 +315,7 @@ def registerDataFrameAsTable(self, df, tableName):
315315
316316
>>> sqlCtx.registerDataFrameAsTable(df, "table1")
317317
"""
318-
if (rdd.__class__ is DataFrame):
318+
if (df.__class__ is DataFrame):
319319
self._ssql_ctx.registerDataFrameAsTable(df._jdf, tableName)
320320
else:
321321
raise ValueError("Can only register DataFrame as table")

0 commit comments

Comments
 (0)