我试图在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
暂无答案!
目前还没有任何答案,快来回答吧!