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

為了賬號(hào)安全,請(qǐng)及時(shí)綁定郵箱和手機(jī)立即綁定
已解決430363個(gè)問題,去搜搜看,總會(huì)有你想問的

在PySpark中爆炸

在PySpark中爆炸

牧羊人nacy 2019-10-21 10:18:06
我想從包含單詞列表的DataFrame轉(zhuǎn)換為每個(gè)單詞都在其自己行中的DataFrame。如何在DataFrame中的列上爆炸?這是我嘗試的一些示例,您可以在其中取消注釋每個(gè)代碼行并獲取以下注釋中列出的錯(cuò)誤。我在帶有Spark 1.6.1的Python 2.7中使用PySpark。from pyspark.sql.functions import split, explodeDF = sqlContext.createDataFrame([('cat \n\n elephant rat \n rat cat', )], ['word'])print 'Dataset:'DF.show()print '\n\n Trying to do explode: \n'DFsplit_explode = ( DF .select(split(DF['word'], ' '))#  .select(explode(DF['word']))  # AnalysisException: u"cannot resolve 'explode(word)' due to data type mismatch: input to function explode should be array or map type, not StringType;"#   .map(explode)  # AttributeError: 'PipelinedRDD' object has no attribute 'show'#   .explode()  # AttributeError: 'DataFrame' object has no attribute 'explode').show()# Trying without splitprint '\n\n Only explode: \n'DFsplit_explode = ( DF  .select(explode(DF['word']))  # AnalysisException: u"cannot resolve 'explode(word)' due to data type mismatch: input to function explode should be array or map type, not StringType;").show()請(qǐng)指教
查看完整描述

3 回答

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

添加回答

舉報(bào)

0/150
提交
取消
微信客服

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

幫助反饋 APP下載

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

公眾號(hào)

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