protected List getUris()

in myriad-scheduler/src/main/java/org/apache/myriad/scheduler/ExecutorCommandLineGenerator.java [143:170]


  protected List<Protos.CommandInfo.URI> getUris() {
    List<Protos.CommandInfo.URI> uris = new ArrayList<>();
    if (myriadExecutorConfiguration.getJvmUri().isPresent()) {
      final String jvmRemoteUri = myriadExecutorConfiguration.getJvmUri().get();
      LOGGER.info("Getting JRE distribution from:" + jvmRemoteUri);
      uris.add(Protos.CommandInfo.URI.newBuilder().setValue(jvmRemoteUri).build());
    }
    if (myriadExecutorConfiguration.getConfigUri().isPresent()) {
      String configURI = myriadExecutorConfiguration.getConfigUri().get();
      LOGGER.info("Getting Hadoop configuration from: {}", configURI);
      uris.add(Protos.CommandInfo.URI.newBuilder().setValue(configURI).build());
    } else if (myriadExecutorConfiguration.getNodeManagerUri().isPresent()) {
      String configURI = getConfigurationUrl();
      LOGGER.info("Getting Hadoop configuration from: {}", configURI);
      uris.add(Protos.CommandInfo.URI.newBuilder().setValue(configURI).build());
    }
    if (myriadExecutorConfiguration.getNodeManagerUri().isPresent()) {
      //Both FrameworkUser and FrameworkSuperuser to get all of the directory permissions correct.
      if (!(myriadConfiguration.getFrameworkUser().isPresent() && myriadConfiguration.getFrameworkSuperUser().isPresent())) {
        LOGGER.warn("Trying to use remote distribution, but frameworkUser and/or frameworkSuperUser not set!" +
            "Some features may not work");
      }
      String nodeManagerUri = myriadExecutorConfiguration.getNodeManagerUri().get();
      LOGGER.info("Getting Hadoop distribution from: {}", nodeManagerUri);
      uris.add(Protos.CommandInfo.URI.newBuilder().setValue(nodeManagerUri).setExtract(false).build());
    }
    return uris;
  }