对于您的问题，java应用程序是否可以与spark一起使用，还是必须重写它们？
是的，你必须重写数据交互层。
spark以rdd/dataframe的形式读取源数据，在您的例子中是它的流Dataframe/数据集。
spark并行处理/作业调度基于这些数据集/Dataframe
dataframes/dataset相当于在多个节点上存储数据的数组。
所以如果java中有一个迭代列表并写入文件的逻辑

conn=openFile(..)
Array[value].foreach{
  value-> {
  updatedValue=/**your business logic on the value**/
  conn.write(updatedValue)
  }
}

在spark中，您必须处理Dataframe

dataframe[value].map{ value->
        updatedValue =/**your business logic on the value**/  <-- reuse your logic here
      }.saveToFile(/**file path**/)

希望您能看到区别，您可以重用您的业务逻辑，但是spark必须处理读/写数据流（推荐）。