flatMap (read_array) bin_df=sqlContext.createDataFrame(unzipped,schema). And now you can do whatever fancy stuff you want in Spark with your dataframe.
確定! 回上一頁