We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 99f3469 commit 5997627Copy full SHA for 5997627
remote_notebook/code/pyspark_kernel/kernel_init.py
@@ -73,4 +73,4 @@ def dataframe():
73
return move_to_local_sqlContext(DataFrame(jdf=java_data_frame, sql_ctx=sqlContext))
74
75
def move_to_local_sqlContext(df):
76
- return sqlContext.createDataFrame(df.rdd)
+ return sqlContext.createDataFrame(df.rdd, df.schema)
0 commit comments