def getFileSystem()

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
    }
  }