使用scala检查临时文件(信号量)是否存在
check if the temporary file(semaphore) exists using scala
请问我如何读取(检查)在我的系统上创建的临时文件。
我需要使用 scala 检查临时文件是否存在,
我该怎么做。
试试这个:
import org.apache.hadoop.conf.Configuration
import org.apache.hadoop.fs.{FileSystem, Path}
val fileSystem = FileSystem.get(new Configuration())
val path = new Path("/tmp/foo/bar/meow.parquet")
if (fileSystem.exists(path)){
// TODO ...
}
它将在本地、Docker 和远程文件系统(S3 和 HDFS)上流畅运行
希望对您有所帮助
请问我如何读取(检查)在我的系统上创建的临时文件。
我需要使用 scala 检查临时文件是否存在,
我该怎么做。
试试这个:
import org.apache.hadoop.conf.Configuration
import org.apache.hadoop.fs.{FileSystem, Path}
val fileSystem = FileSystem.get(new Configuration())
val path = new Path("/tmp/foo/bar/meow.parquet")
if (fileSystem.exists(path)){
// TODO ...
}
它将在本地、Docker 和远程文件系统(S3 和 HDFS)上流畅运行
希望对您有所帮助