如果计划基于单个输入流Dataframe编写四个不同的Dataframe，则可以使用 foreachBatch 按以下方式：

streamingDF.writeStream.foreachBatch { (batchDF: DataFrame, batchId: Long) =>
  // as you plan to use the batchDF to create multiple output it might be wort persisting the batchDF
  batchDF.persist()
  // create the four different Dataframes based on the input
  val ProjectDf = batchDF.select(...)
  val LocationDf = batchDF.select(...) 
  val ContactDf = batchDF.select(...)
  val EmployeeDf = batchDF.select(...)
  // then you can save those four Dataframes into the desired locations
  ProjectDf.write.format("spark.sqldw").options(.dbo.Project).save(...)
  LocationDf.write.format("spark.sqldw").options(.dbo.Loc).save(...)
  ContactDf.write.format("spark.sqldw").options(.dbo.Contact).save(...)
  EmployeeDf.write.format("spark.sqldw").options(.dbo.Emp).save(...)
  // do not forget to unpersist your batchDF
  batchDF.unpersist()
}

有关使用foreach和foreachbatch的文档中对此进行了描述
如果遇到异常“overloaded method foreachbatch with alternatives”，可以查看databricks runtime 7.0的发行说明，其中说明：
要修复编译错误，请更改 foreachBatch { (df, id) => myFunc(df, id) } 至 foreachBatch(myFunc _) 或者显式使用java api:foreachbatch（new voidfunction2…）
也就是说，您的代码如下所示：

def myFunc(batchDF: DataFrame, batchId: Long): Unit = {
  // as you plan to use the batchDF to create multiple output it might be wort persisting the batchDF
  batchDF.persist()
  // create the four different Dataframes based on the input
  val ProjectDf = batchDF.select(...)
  val LocationDf = batchDF.select(...) 
  val ContactDf = batchDF.select(...)
  val EmployeeDf = batchDF.select(...)
  // then you can save those four Dataframes into the desired locations
  ProjectDf.write.format("spark.sqldw").options(.dbo.Project).save(...)
  LocationDf.write.format("spark.sqldw").options(.dbo.Loc).save(...)
  ContactDf.write.format("spark.sqldw").options(.dbo.Contact).save(...)
  EmployeeDf.write.format("spark.sqldw").options(.dbo.Emp).save(...)
  // do not forget to unpersist your batchDF
  batchDF.unpersist()
}
streamingDF.writeStream.foreachBatch(myFunc _).[...].start()