取消
顯示的結果
而不是尋找
你的意思是:

如何閱讀列使用pyspark動態嗎

Enthusiastic_Da
新的因素

我有一個表稱為元數據和需要哪些列中選擇存儲在MetaData.columns

我想讀列從元數據動態。基於這列和創建一個視圖。

col1 csv_values = ",則col2、col3 col4”

df = spark.createDataFrame (((csv_values)], [" csv_column "])

df = df。選擇(分裂(df (“csv_column”)”、“) .alias (“array_column”))

df1 = spark.read.format(“鋪”).load (FilePath) .select (df (“*”))

像下麵這段代碼拋出錯誤

意想不到的異常格式異常。回落到標準的例外

0回答0
歡迎來到磚社區:讓學習、網絡和一起慶祝

加入我們的快速增長的數據專業人員和專家的80 k +社區成員,準備發現,幫助和合作而做出有意義的聯係。

點擊在這裏注冊今天,加入!

參與令人興奮的技術討論,加入一個組與你的同事和滿足我們的成員。

Baidu
map