嗨親愛的社區,
我公司是在遷移項目從MapR磚,我們有以下的代碼,用於在這個平台正常工作但是一旦在磚,它停止工作。Beplay体育安卓版本我注意到這是失敗與他人和這個特定的正則表達式的值隻是因為這是沒有得到任何錯誤。
錯誤是“錯誤而獲得一個新的溝通渠道”之後,我們不能繼續寫代碼和測試,碎了。
我附上截圖供參考。
進口pyspark.sql。函數作為pyfunc
df = spark.read.parquet (“/ mnt / gpdipedlstgamrasp50565 / stg_db /中級/ ODX / ODW / STUDY_REPORT /電流/數據/”)
df.count ()
df = df。withColumn (CSR_RESULTS_SUMMARY, pyfunc.regexp_replace (pyfunc.col (“CSR_RESULTS_SUMMARY”), u”([\ ud800 - \ udfff \ ufdd0 - \ ufdef \ ufffe \ uffff +])”,“))
df.show ()
非常感謝你提前。