foreachBatch在spark哪个版本中

在这句代码我将test用流式的方式写ES，但是这个foreachbatch报没有此方法的错误，请问这个放在在哪个版本的spark中或者在哪个jar报中，谢谢
test.writeStream.outputMode("update").option("checkpointLocation", chkp_es).foreachBatch

http://spark.coolplayer.net/?p=3132