幫助
康斯坦丁
貢獻者三世
自 ‎11-02-2021
兩個星期前

用戶數據

  • 18的帖子
  • 0解決方案
  • 6榮譽給
  • 34榮譽收到

用戶活動

錯誤使用PySpark編寫dataframe s3位置時

06-02-2022
我得到一個錯誤,當寫作dataframe s3位置發現無效的字符(s)在",{}()\ n \ t = "的列名yourI經曆了所有列,沒有人有任何特殊字符。知道如何解決這個問題嗎?

我們可以重用檢查站引發流嗎?

04-26-2022
我正在讀數據從一個卡夫卡的話題,說topic_a。我有一個應用程序中,app_one使用火花從topic_a流讀取數據。我有一個檢查點位置,loc_a存儲檢查點。現在,app_one讀取數據到抵消90。我可以創造……

如何提供PySpark UPSERT條件

04-13-2022
我有一個表“demo_table_one”,我想插入以下valuesdata =[(11111年,“CA”,“2020-01-26”),(11111年,“CA”,“2020-02-26”),(88888年,“CA”,“2020-06-10”),(88888年,“CA”,“2020-05-10”),(88888年,“佤邦”,“2020-07-10”),…

三角洲表上創建s3 null值

04-11-2022
我有火花Dataframe中的數據和我寫一個s3的位置。它有一些複雜的數據類型結構等。當我在s3創建表頂部位置通過使用三角洲創建表如果不存在table_name s3: / /…/…的位置;Th……

無法創建分區表在s3數據

04-10-2022
我寫數據到s3像data.write.format(“δ”).mode(“追加”)。選項(“mergeSchema”,“真正的”).save (s3_location)和創建一個分區表likeCREATE表如果不存在demo_table用δ分區(column_a)位置{s3_location}; whi……
查看更多
Baidu
map