Examples of ProgramClassLoader

co.cask.cdap.common.lang.jar.ProgramClassLoader
ClassLoader that implements bundle jar feature, in which the application jar contains its dependency jars inside the "/lib" folder (by default) within the application jar.
Useful for using third party jars that overwrite each other's files (e.g. Datanucleus jars each have plugin.xml at same location relative to the jar root, so if you package your application as an uber-jar, your application jar will only contain one of the plugin.xml at best unless you do some manual configuration.
Not (yet) useful for avoiding classpath conflicts with CDAP's dependency jars (e.g. you want to use Guava 16.0.1 but CDAP uses 13.0.1)
co.cask.tigon.lang.jar.ProgramClassLoader
ClassLoader that implements bundle jar feature, in which the application jar contains its dependency jars inside the "/lib" folder (by default) within the application jar.
Useful for 1) using third party jars that overwrite each other's files (e.g. Datanucleus jars each have plugin.xml at same location relative to the jar root, so if you package your application as an uber-jar, your application jar will only contain one of the plugin.xml at best unless you do some manual configuration.
Not (yet) useful for 1) avoiding classpath conflicts with Tigon's dependency jars (e.g. you want to use Guava 16.0.1 but Tigon uses 13.0.1)

Examples of co.cask.cdap.common.lang.jar.ProgramClassLoader

                                                         ClassLoader parentClassLoader) throws IOException {
    // TODO: Unify the creation of FilterClassLoader, see CDAP-6
    Predicate<String> predicate = Predicates.in(Sets.newHashSet(apiResourceList));
    ClassLoader filterParent = Objects.firstNonNull(Thread.currentThread().getContextClassLoader(),
                                                    ClassLoaders.class.getClassLoader());
    return new ProgramClassLoader(unpackedJarDir, new CombineClassLoader(new FilterClassLoader(predicate, filterParent),
                                                                         ImmutableList.of(parentClassLoader)));
  }

View Full Code Here

Examples of co.cask.cdap.common.lang.jar.ProgramClassLoader

    // deploy dataset modules
    ApplicationSpecification specification = input.getSpecification();
    File unpackedLocation = Files.createTempDir();
    try {
      BundleJarUtil.unpackProgramJar(input.getArchive(), unpackedLocation);
      ProgramClassLoader classLoader = ClassLoaders.newProgramClassLoader(unpackedLocation,
                                                                          ApiResourceListHolder.getResourceList(),
                                                                          this.getClass().getClassLoader());
      for (Map.Entry<String, String> moduleEntry : specification.getDatasetModules().entrySet()) {
        // note: using app class loader to load module class
        @SuppressWarnings("unchecked")
        Class<?> clazz = classLoader.loadClass(moduleEntry.getValue());
        String moduleName = moduleEntry.getKey();
        try {
          // note: we can deploy module or create module from Dataset class
          // note: it seems dangerous to instantiate dataset module here, but this will be fine when we move deploy into
          //       isolated user's environment (e.g. separate yarn container)

View Full Code Here

Examples of co.cask.cdap.common.lang.jar.ProgramClassLoader

    this.appFabricClient = new AppFabricClient(httpHandler, serviceHttpHandler, locationFactory);


    try {
      File tempDir = tempFolder.newFolder();
      BundleJarUtil.unpackProgramJar(deployedJar, tempDir);
      ProgramClassLoader classLoader = ClassLoaders.newProgramClassLoader
        (tempDir, ApiResourceListHolder.getResourceList(), this.getClass().getClassLoader());
      this.dataSetInstantiator = new DataSetInstantiator(datasetFramework, configuration,
                                                         new DataSetClassLoader(classLoader),
                                                         // todo: collect metrics for datasets outside programs too
                                                         null, null);

View Full Code Here

Examples of co.cask.tigon.lang.jar.ProgramClassLoader

    }
  }


  public Program createProgram(File jarPath, String classToLoad, File jarUnpackDir) throws Exception {
    expandJar(jarPath, jarUnpackDir);
    ProgramClassLoader classLoader = ClassLoaders.newProgramClassLoader(jarUnpackDir,
                                                                        ApiResourceListHolder.getResourceList());
    Class<?> clz = classLoader.loadClass(classToLoad);
    if (!(clz.newInstance() instanceof Flow)) {
      throw new Exception("Expected Flow class");
    }
    ClassLoader contextClassLoader = Thread.currentThread().getContextClassLoader();
    Thread.currentThread().setContextClassLoader(classLoader);

View Full Code Here

Examples of co.cask.tigon.lang.jar.ProgramClassLoader

  public static ProgramClassLoader newProgramClassLoader(File unpackedJarDir,
                                                         Iterable<String> apiResourceList) throws IOException {
    Predicate<String> predicate = Predicates.in(Sets.newHashSet(apiResourceList));
    ClassLoader filterParent = Objects.firstNonNull(Thread.currentThread().getContextClassLoader(),
                                                    ClassLoaders.class.getClassLoader());
    return new ProgramClassLoader(unpackedJarDir, new FilterClassLoader(predicate, filterParent));
  }

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.