第七色在线视频,2021少妇久久久久久久久久,亚洲欧洲精品成人久久av18,亚洲国产精品特色大片观看完整版,孙宇晨将参加特朗普的晚宴

為了賬號安全,請及時綁定郵箱和手機立即綁定
已解決430363個問題,去搜搜看,總會有你想問的

數(shù)據(jù)框到rdd python / spark / pyspark

數(shù)據(jù)框到rdd python / spark / pyspark

慕妹3242003 2021-04-05 16:13:26
我使用的是舊的pyspark腳本。我正在嘗試將數(shù)據(jù)幀df轉(zhuǎn)換為rdd。#Importing the required librariesimport pandas as pdfrom pyspark.sql.types import *from pyspark.ml.regression import RandomForestRegressorfrom pyspark.mllib.util import MLUtilsfrom pyspark.ml import Pipelinefrom pyspark.ml.tuning import CrossValidator, ParamGridBuilderfrom pyspark.ml.evaluation import RegressionEvaluatorfrom pyspark.ml.linalg import Vectorsfrom pyspark.ml import Pipelinefrom pyspark.ml.tuning import CrossValidator, ParamGridBuilderfrom pyspark.mllib.fpm import *from pyspark.sql import SparkSessionspark = SparkSession     .builder     .appName("Python Spark")     .config("spark.some.config.option", "some-value")# read the datadf = pd.read_json("events.json")df = (df.rdd.map(lambda x: (x[1],[x[0]])).reduceByKey(lambda x,y: x+y).sortBy(lambda k_v: (k_v[0], sorted(k_v[1], key=lambda x: x[1], reverse=True))).collect())           繼承人錯誤輸出: AttributeError:'DataFrame'對象沒有屬性'rdd'我想念什么?如何將數(shù)據(jù)幀轉(zhuǎn)換為rdd?我安裝了anaconda 3.6.1和spark 2.3.1
查看完整描述

1 回答

  • 1 回答
  • 0 關(guān)注
  • 169 瀏覽
慕課專欄
更多

添加回答

舉報

0/150
提交
取消
微信客服

購課補貼
聯(lián)系客服咨詢優(yōu)惠詳情

幫助反饋 APP下載

慕課網(wǎng)APP
您的移動學(xué)習(xí)伙伴

公眾號

掃描二維碼
關(guān)注慕課網(wǎng)微信公眾號