Skip to content

Commit b163365

Browse files
committed
Python fix. Added Experimental flag to DataFrameNaFunctions.
1 parent 608422d commit b163365

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

python/pyspark/sql/context.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -316,8 +316,7 @@ def registerDataFrameAsTable(self, df, tableName):
316316
>>> sqlCtx.registerDataFrameAsTable(df, "table1")
317317
"""
318318
if (rdd.__class__ is DataFrame):
319-
df = rdd._jdf
320-
self._ssql_ctx.registerDataFrameAsTable(df, tableName)
319+
self._ssql_ctx.registerDataFrameAsTable(df._jdf, tableName)
321320
else:
322321
raise ValueError("Can only register DataFrame as table")
323322

sql/core/src/main/scala/org/apache/spark/sql/DataFrameNaFunctions.scala

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,14 +21,17 @@ import java.{lang => jl}
2121

2222
import scala.collection.JavaConversions._
2323

24+
import org.apache.spark.annotation.Experimental
2425
import org.apache.spark.sql.catalyst.expressions._
2526
import org.apache.spark.sql.functions._
2627
import org.apache.spark.sql.types._
2728

2829

2930
/**
31+
* :: Experimental ::
3032
* Functionality for working with missing data in [[DataFrame]]s.
3133
*/
34+
@Experimental
3235
final class DataFrameNaFunctions private[sql](df: DataFrame) {
3336

3437
/**

0 commit comments

Comments
 (0)