@Test (timeout = 5000) public void testRunCommandNoPriority() throws Exception { Configuration conf = new Configuration(); String[] command = containerExecutor.getRunCommand("echo", "group1", "user", null, conf); assertTrue("first command should be the run command for the platform", command[0].equals(Shell.WINUTILS) || command[0].equals("bash")); }
protected String[] getRunCommand(String command, String groupId, String userName, Path pidFile, Configuration conf) { return getRunCommand(command, groupId, userName, pidFile, conf, null); }
ContainerExecutor implements Configurable { protected String[] getRunCommand(String command, String groupId, String userName, Path pidFile, Configuration conf) { return getRunCommand(command, groupId, userName, pidFile, conf, null); } }
ContainerExecutor implements Configurable { protected String[] getRunCommand(String command, String groupId, String userName, Path pidFile, Configuration conf) { return getRunCommand(command, groupId, userName, pidFile, conf, null); }  }
ContainerExecutor implements Configurable { protected String[] getRunCommand(String command, String groupId, String userName, Path pidFile, Configuration conf) { return getRunCommand(command, groupId, userName, pidFile, conf, null); }  @Override void setConf(Configuration conf); @Override Configuration getConf(); abstract void init(); Path localizeClasspathJar(Path classPathJar, Path pwd, String owner); abstract void startLocalizer(LocalizerStartContext ctx); abstract int prepareContainer(ContainerStartContext ctx); abstract int launchContainer(ContainerStartContext ctx); abstract boolean signalContainer(ContainerSignalContext ctx); abstract void deleteAsUser(DeletionAsUserContext ctx); abstract boolean isContainerAlive(ContainerLivenessContext ctx); int reacquireContainer(ContainerReacquisitionContext ctx); void writeLaunchEnv(OutputStream out, Map<String, String> environment, Map<Path, List<String>> resources, List<String> command); void activateContainer(ContainerId containerId, Path pidFilePath); void deactivateContainer(ContainerId containerId); String getProcessId(ContainerId containerID); }
ContainerExecutor implements Configurable { protected String[] getRunCommand(String command, String groupId, String userName, Path pidFile, Configuration conf) { return getRunCommand(command, groupId, userName, pidFile, conf, null); }  @Override void setConf(Configuration conf); @Override Configuration getConf(); abstract void init(); Path localizeClasspathJar(Path classPathJar, Path pwd, String owner); abstract void startLocalizer(LocalizerStartContext ctx); abstract int prepareContainer(ContainerStartContext ctx); abstract int launchContainer(ContainerStartContext ctx); abstract boolean signalContainer(ContainerSignalContext ctx); abstract void deleteAsUser(DeletionAsUserContext ctx); abstract boolean isContainerAlive(ContainerLivenessContext ctx); int reacquireContainer(ContainerReacquisitionContext ctx); void writeLaunchEnv(OutputStream out, Map<String, String> environment, Map<Path, List<String>> resources, List<String> command); void activateContainer(ContainerId containerId, Path pidFilePath); void deactivateContainer(ContainerId containerId); String getProcessId(ContainerId containerID); final static FsPermission TASK_LAUNCH_SCRIPT_PERMISSION; }