为什么我得到的错误和foreachbatch在哪个jar或spark版本?

6jygbczu  于 2021-05-27  发布在  Spark
关注(0)|答案(0)|浏览(216)

我试图在sparkstream中使用foreachbatch方法,但是我得到了一个错误:无法解析symbol foreachbatch并检查spark api,我仍然找不到这个方法
http://spark.apache.org/docs/2.3.0/api/java/org/apache/spark/sql/streaming/datastreamwriter.html
我想知道foreachbatch方法在哪个jar或spark版本,thx,qaq

test.writeStream.outputMode("update").option("checkpointLocation", chkp_es).foreachBatch

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题