你好,
我想寫一個流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
你能幫我找到這個包,如何導入它嗎?
