本文整理了Java中org.apache.hadoop.yarn.webapp.test.WebAppTests.flushOutput()方法的一些代码示例，展示了WebAppTests.flushOutput()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。WebAppTests.flushOutput()方法的具体详情如下：
包路径：org.apache.hadoop.yarn.webapp.test.WebAppTests
类名称：WebAppTests
方法名：flushOutput

WebAppTests.flushOutput介绍

暂无

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

@Test
public void testNodesBlockRender() throws Exception {
 injector.getInstance(NodesBlock.class).render();
 PrintWriter writer = injector.getInstance(PrintWriter.class);
 WebAppTests.flushOutput(injector);
 Mockito.verify(writer,
   Mockito.times(numberOfActualTableHeaders + numberOfThInMetricsTable))
   .print("<th");
 Mockito.verify(writer, Mockito.times(numberOfThInMetricsTable))
   .print("<td");
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

@Test
public void testNodesBlockRender() throws Exception {
 injector.getInstance(NodesBlock.class).render();
 PrintWriter writer = injector.getInstance(PrintWriter.class);
 WebAppTests.flushOutput(injector);
 Mockito.verify(writer,
   Mockito.times(numberOfActualTableHeaders + numberOfThInMetricsTable))
   .print("<th");
 Mockito.verify(
   writer,
   Mockito.times(numberOfRacks * numberOfNodesPerRack
     * numberOfActualTableHeaders + numberOfThInMetricsTable)).print(
   "<td");
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

@Test
public void testNodesBlockRenderForNodeLabelFilterWithNonEmptyLabel() {
 NodesBlock nodesBlock = injector.getInstance(NodesBlock.class);
 nodesBlock.set("node.label", "x");
 nodesBlock.render();
 PrintWriter writer = injector.getInstance(PrintWriter.class);
 WebAppTests.flushOutput(injector);
 Mockito.verify(writer, Mockito.times(numberOfThInMetricsTable))
   .print("<td");
 Mockito.verify(writer, Mockito.times(1)).print("<script");
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

@Test
public void testNodesBlockRenderForNodeLabelFilterWithAnyLabel() {
 NodesBlock nodesBlock = injector.getInstance(NodesBlock.class);
 nodesBlock.set("node.label", "*");
 nodesBlock.render();
 PrintWriter writer = injector.getInstance(PrintWriter.class);
 WebAppTests.flushOutput(injector);
 Mockito.verify(writer, Mockito.times(numberOfThInMetricsTable))
   .print("<td");
}

代码示例来源：origin: io.hops/hadoop-yarn-common

public static <T> Injector testBlock(Class<? extends SubView> block,
  Class<T> api, T impl, Module... modules) {
 Injector injector = createMockInjector(api, impl, modules);
 injector.getInstance(block).renderPartial();
 flushOutput(injector);
 return injector;
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

@Test
public void testNodesBlockRenderForLostNodes() {
 NodesBlock nodesBlock = injector.getInstance(NodesBlock.class);
 nodesBlock.set("node.state", "lost");
 nodesBlock.render();
 PrintWriter writer = injector.getInstance(PrintWriter.class);
 WebAppTests.flushOutput(injector);
 Mockito.verify(writer,
   Mockito.times(numberOfActualTableHeaders + numberOfThInMetricsTable))
   .print("<th");
 Mockito.verify(writer, Mockito.times(numberOfThInMetricsTable))
   .print("<td");
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-common

public static <T> Injector testBlock(Class<? extends SubView> block,
  Class<T> api, T impl, Module... modules) {
 Injector injector = createMockInjector(api, impl, modules);
 injector.getInstance(block).renderPartial();
 flushOutput(injector);
 return injector;
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

@Test
public void testNodesBlockRenderForNodeLabelFilterWithEmptyLabel() {
 NodesBlock nodesBlock = injector.getInstance(NodesBlock.class);
 nodesBlock.set("node.label", "");
 nodesBlock.render();
 PrintWriter writer = injector.getInstance(PrintWriter.class);
 WebAppTests.flushOutput(injector);
 Mockito.verify(writer, Mockito.times(numberOfThInMetricsTable))
   .print("<td");
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-common

public static <T> Injector testBlock(Class<? extends SubView> block,
  Class<T> api, T impl, Module... modules) {
 Injector injector = createMockInjector(api, impl, modules);
 injector.getInstance(block).renderPartial();
 flushOutput(injector);
 return injector;
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

@Test
public void testNodesBlockRenderForNodeLabelFilterWithNonEmptyLabel() {
 NodesBlock nodesBlock = injector.getInstance(NodesBlock.class);
 nodesBlock.set("node.label", "x");
 nodesBlock.render();
 PrintWriter writer = injector.getInstance(PrintWriter.class);
 WebAppTests.flushOutput(injector);
 Mockito.verify(
   writer,
   Mockito.times(numberOfRacks
     * numberOfActualTableHeaders + numberOfThInMetricsTable)).print(
   "<td");
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

@Test
public void testNodesBlockRenderForNodeLabelFilterWithEmptyLabel() {
 NodesBlock nodesBlock = injector.getInstance(NodesBlock.class);
 nodesBlock.set("node.label", "");
 nodesBlock.render();
 PrintWriter writer = injector.getInstance(PrintWriter.class);
 WebAppTests.flushOutput(injector);
 Mockito.verify(
   writer,
   Mockito.times(numberOfRacks * (numberOfNodesPerRack - 1)
     * numberOfActualTableHeaders + numberOfThInMetricsTable)).print(
   "<td");
}

代码示例来源：origin: io.hops/hadoop-yarn-common

public static <T> Injector testPage(Class<? extends View> page, Class<T> api,
                  T impl, Map<String,String> params, Module... modules) {
 Injector injector = createMockInjector(api, impl, modules);
 View view = injector.getInstance(page);
 if(params != null) {
  for(Map.Entry<String, String> entry: params.entrySet()) {
   view.set(entry.getKey(), entry.getValue());
  }
 }
 view.render();
 flushOutput(injector);
 return injector;
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-common

public static <T> Injector testPage(Class<? extends View> page, Class<T> api,
                  T impl, Map<String,String> params, Module... modules) {
 Injector injector = createMockInjector(api, impl, modules);
 View view = injector.getInstance(page);
 if(params != null) {
  for(Map.Entry<String, String> entry: params.entrySet()) {
   view.set(entry.getKey(), entry.getValue());
  }
 }
 view.render();
 flushOutput(injector);
 return injector;
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-common

public static <T> Injector testPage(Class<? extends View> page, Class<T> api,
                  T impl, Map<String,String> params, Module... modules) {
 Injector injector = createMockInjector(api, impl, modules);
 View view = injector.getInstance(page);
 if(params != null) {
  for(Map.Entry<String, String> entry: params.entrySet()) {
   view.set(entry.getKey(), entry.getValue());
  }
 }
 view.render();
 flushOutput(injector);
 return injector;
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

@Test
 public void testNodesBlockRenderForNodeLabelFilterWithAnyLabel() {
  NodesBlock nodesBlock = injector.getInstance(NodesBlock.class);
  nodesBlock.set("node.label", "*");
  nodesBlock.render();
  PrintWriter writer = injector.getInstance(PrintWriter.class);
  WebAppTests.flushOutput(injector);

  Mockito.verify(
    writer,
    Mockito.times(numberOfRacks * numberOfNodesPerRack
      * numberOfActualTableHeaders + numberOfThInMetricsTable)).print(
    "<td");
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-applicationhistoryservice

@Test
public void testAboutPage() throws Exception {
 Injector injector =
   WebAppTests.createMockInjector(ApplicationBaseProtocol.class,
     mockApplicationHistoryClientService(0, 0, 0));
 AboutPage aboutPageInstance = injector.getInstance(AboutPage.class);
 aboutPageInstance.render();
 WebAppTests.flushOutput(injector);
 aboutPageInstance.render();
 WebAppTests.flushOutput(injector);
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-applicationhistoryservice

@Test
public void testAppPage() throws Exception {
 Injector injector =
   WebAppTests.createMockInjector(ApplicationBaseProtocol.class,
    mockApplicationHistoryClientService(1, 5, 1));
 AppPage appPageInstance = injector.getInstance(AppPage.class);
 appPageInstance.render();
 WebAppTests.flushOutput(injector);
 appPageInstance.set(YarnWebParams.APPLICATION_ID, ApplicationId
  .newInstance(0, 1).toString());
 appPageInstance.render();
 WebAppTests.flushOutput(injector);
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-applicationhistoryservice

@Test
public void testAPPViewNaturalSortType() throws Exception {
 Injector injector =
   WebAppTests.createMockInjector(ApplicationBaseProtocol.class,
     mockApplicationHistoryClientService(5, 1, 1));
 AHSView ahsViewInstance = injector.getInstance(AHSView.class);
 ahsViewInstance.render();
 WebAppTests.flushOutput(injector);
 Map<String, String> moreParams =
   ahsViewInstance.context().requestContext().moreParams();
 String appTableColumnsMeta = moreParams.get("ui.dataTables.apps.init");
 Assert.assertTrue(appTableColumnsMeta.indexOf("natural") != -1);
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-applicationhistoryservice

@Test
public void testAppPageNaturalSortType() throws Exception {
 Injector injector =
   WebAppTests.createMockInjector(ApplicationBaseProtocol.class,
     mockApplicationHistoryClientService(1, 5, 1));
 AppPage appPageInstance = injector.getInstance(AppPage.class);
 appPageInstance.render();
 WebAppTests.flushOutput(injector);
 Map<String, String> moreParams =
   appPageInstance.context().requestContext().moreParams();
 String attemptsTableColumnsMeta =
   moreParams.get("ui.dataTables.attempts.init");
 Assert.assertTrue(attemptsTableColumnsMeta.indexOf("natural") != -1);
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-applicationhistoryservice

@Test
public void testAppAttemptPageNaturalSortType() throws Exception {
 Injector injector =
   WebAppTests.createMockInjector(ApplicationBaseProtocol.class,
     mockApplicationHistoryClientService(1, 1, 5));
 AppAttemptPage appAttemptPageInstance =
   injector.getInstance(AppAttemptPage.class);
 appAttemptPageInstance.render();
 WebAppTests.flushOutput(injector);
 Map<String, String> moreParams =
   appAttemptPageInstance.context().requestContext().moreParams();
 String tableColumnsMeta = moreParams.get("ui.dataTables.containers.init");
 Assert.assertTrue(tableColumnsMeta.indexOf("natural") != -1);
}