We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a0c3dab commit fe841d2Copy full SHA for fe841d2
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