org.apache.spark.sql.execution.streaming.sources.ForeachWriterSuite

(It is not a test it is a sbt.testing.SuiteSelector)
foreach sink should support metrics
foreach with error
foreach with error not caused by ForeachWriter
foreach with watermark: append
foreach with watermark: complete
foreach() with `append` output mode
foreach() with `complete` output mode