@Test public void testWithHdfsDefaultFs() { MRLocalCluster mrLocalCluster = new MRLocalCluster.Builder() .setNumNodeManagers(Integer.parseInt(propertyParser.getProperty(ConfigVars.YARN_NUM_NODE_MANAGERS_KEY))) .setJobHistoryAddress(propertyParser.getProperty(ConfigVars.MR_JOB_HISTORY_ADDRESS_KEY)) .setResourceManagerAddress(propertyParser.getProperty(ConfigVars.YARN_RESOURCE_MANAGER_ADDRESS_KEY)) .setResourceManagerHostname(propertyParser.getProperty(ConfigVars.YARN_RESOURCE_MANAGER_HOSTNAME_KEY)) .setResourceManagerSchedulerAddress(propertyParser.getProperty( ConfigVars.YARN_RESOURCE_MANAGER_SCHEDULER_ADDRESS_KEY)) .setResourceManagerResourceTrackerAddress(propertyParser.getProperty( ConfigVars.YARN_RESOURCE_MANAGER_RESOURCE_TRACKER_ADDRESS_KEY)) .setResourceManagerWebappAddress(propertyParser.getProperty( ConfigVars.YARN_RESOURCE_MANAGER_WEBAPP_ADDRESS_KEY)) .setUseInJvmContainerExecutor(Boolean.parseBoolean(propertyParser.getProperty( ConfigVars.YARN_USE_IN_JVM_CONTAINER_EXECUTOR_KEY))) .setHdfsDefaultFs("hdfs: .setConfig(new Configuration()) .build(); assertEquals("hdfs: }
public String getHdfsDefaultFs() { return hdfsDefaultFs; }
MRLocalCluster implements MiniCluster { public String getHdfsDefaultFs() { return hdfsDefaultFs; } }
MRLocalCluster implements MiniCluster { public String getHdfsDefaultFs() { return hdfsDefaultFs; } private  MRLocalCluster(Builder builder); }
MRLocalCluster implements MiniCluster { public String getHdfsDefaultFs() { return hdfsDefaultFs; } private  MRLocalCluster(Builder builder); String getTestName(); Integer getNumNodeManagers(); String getJobHistoryAddress(); String getResourceManagerAddress(); String getResourceManagerHostname(); String getResourceManagerSchedulerAddress(); String getResourceManagerResourceTrackerAddress(); String getResourceManagerWebappAddress(); Boolean getUseInJvmContainerExecutor(); String getHdfsDefaultFs(); Configuration getConfig(); @Override void start(); @Override void stop(); @Override void stop(boolean cleanUp); @Override void configure(); @Override void cleanUp(); }
MRLocalCluster implements MiniCluster { public String getHdfsDefaultFs() { return hdfsDefaultFs; } private  MRLocalCluster(Builder builder); String getTestName(); Integer getNumNodeManagers(); String getJobHistoryAddress(); String getResourceManagerAddress(); String getResourceManagerHostname(); String getResourceManagerSchedulerAddress(); String getResourceManagerResourceTrackerAddress(); String getResourceManagerWebappAddress(); Boolean getUseInJvmContainerExecutor(); String getHdfsDefaultFs(); Configuration getConfig(); @Override void start(); @Override void stop(); @Override void stop(boolean cleanUp); @Override void configure(); @Override void cleanUp();  }