Java中的自定義ClassLoader用於從hdfs加載jar

Question

我想在我的程序中使用自定義Java URL ClassLoader從HDFS加載一個jar。 我找不到互聯網上的例子。我已經看到在下列螺紋提到加載從本地文件系統罐子例子：

Custom URLClassLoader

任何建議或工作的例子嗎？

謝謝。

Answer 1

這是如何編寫自定義類加載器的。代碼是用scala編寫的。你可以把它轉換成java。

class HdfsClassLoaderclassLoader(classLoader: ClassLoader) extends URLClassLoader(Array.ofDim[URL](0), classLoader) { 

    def addJarToClasspath(jarName: String) { 
     synchronized { 
      var conf = new Configuration 
      val fileSystem = FileSystem.get(conf) 
      val path = new Path(jarName); 
      if (!fileSystem.exists(path)) { 
       println("File does not exists") 
      } 
      val uriPath = path.toUri() 
      val urlPath = uriPath.toURL() 
      println(urlPath.getFile) 
      addURL(urlPath) 
     } 
    } 
}