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

給DynamoDB流輸出

sudhanshu1
新的貢獻者三世

你好,

我想寫一個流DF dynamoDB下麵代碼。

tumbling_df。writeStream \

.format \ (“org.apache.spark.sql.execution.streaming.sinks.DynamoDBSinkProvider”)

.option(“地區”、“eu-west-2”) \

.option(“表”、“PythonForeachTest”) \

.outputMode \(“更新”)

.start ()

但是我得到一個錯誤

Py4JJavaError:調用o3880.start時發生一個錯誤。

:java.lang.ClassNotFoundException:

沒有找到數據來源:org.apache.spark.sql.execution.streaming.sinks.DynamoDBSinkProvider。請找到包

http://spark.apache.org/third-party-projects.html

你能幫我找到這個包,如何導入它嗎?

1回複1

LandanG
尊敬的貢獻者
尊敬的貢獻者

嗨@SUDHANSHU RAJ,

我似乎無法找到很多“DynamoDBSinkProvider”來源。你檢查的鏈接嗎流到DynamoDB文檔嗎?

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

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

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

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

Baidu
map