in measure/src/main/scala/org/apache/griffin/measure/utils/FSUtil.scala [35:54]
def getFileSystem(path: String): FileSystem = {
getUriOpt(path) match {
case Some(uri) =>
fsMap.get(uri.getScheme) match {
case Some(fs) => fs
case _ =>
val fs =
try {
FileSystem.get(uri, getConfiguration)
} catch {
case e: Throwable =>
error(s"get file system error: ${e.getMessage}", e)
throw e
}
fsMap += (uri.getScheme -> fs)
fs
}
case _ => defaultFS
}
}