Mor*_*itz 12
对于像我这样的简单任务,我会使用scala.io.Source.一个例子看起来像这样:
val input = io.Source.fromFile("input.csv").getLines()
if (input.hasNext) {
// assuming one header line
val header = List(input.next())
for ((i, lines) <- Iterator.from(1) zip input.grouped(linesPerFile)) {
val out = createWriter(i) // Create a file for index i
(header.iterator ++ lines.iterator).foreach(out.println)
out.close
}
}
Run Code Online (Sandbox Code Playgroud)