1. 包列表
  2. 类列表
  3. org.apache.hadoop.mapred.gridmix.emulators.resourceusage.TotalHeapUsageEmulatorPlugin

Java 类org.apache.hadoop.mapred.gridmix.emulators.resourceusage.TotalHeapUsageEmulatorPlugin 实例源码

项目：hadoop    文件：TestGridmixMemoryEmulation.java    
private static void testEmulationAccuracy(Configuration conf, 
                      FakeHeapUsageEmulatorCore fakeCore,
                      ResourceCalculatorPlugin monitor,
                      ResourceUsageMetrics metrics,
                      TotalHeapUsageEmulatorPlugin heapPlugin,
                      long expectedTotalHeapUsageInMB,
                      long expectedTotalNumCalls)
throws Exception {
  FakeProgressive fakeProgress = new FakeProgressive();
  fakeCore.resetFake();
  heapPlugin.initialize(conf, metrics, monitor, fakeProgress);
  int numLoops = 0;
  while (fakeProgress.getProgress() < 1) {
    ++numLoops;
    float progress = numLoops / 100.0F;
    fakeProgress.setProgress(progress);
    heapPlugin.emulate();
  }

  // test if the resource plugin shows the expected usage
  assertEquals("Cumulative heap usage emulator plugin failed (total usage)!", 
               expectedTotalHeapUsageInMB, fakeCore.getHeapUsageInMB(), 1L);
  // test if the resource plugin shows the expected num calls
  assertEquals("Cumulative heap usage emulator plugin failed (num calls)!", 
               expectedTotalNumCalls, fakeCore.getNumCalls(), 0L);
}
项目：aliyun-oss-hadoop-fs    文件：TestGridmixMemoryEmulation.java    
private static void testEmulationAccuracy(Configuration conf, 
                      FakeHeapUsageEmulatorCore fakeCore,
                      ResourceCalculatorPlugin monitor,
                      ResourceUsageMetrics metrics,
                      TotalHeapUsageEmulatorPlugin heapPlugin,
                      long expectedTotalHeapUsageInMB,
                      long expectedTotalNumCalls)
throws Exception {
  FakeProgressive fakeProgress = new FakeProgressive();
  fakeCore.resetFake();
  heapPlugin.initialize(conf, metrics, monitor, fakeProgress);
  int numLoops = 0;
  while (fakeProgress.getProgress() < 1) {
    ++numLoops;
    float progress = numLoops / 100.0F;
    fakeProgress.setProgress(progress);
    heapPlugin.emulate();
  }

  // test if the resource plugin shows the expected usage
  assertEquals("Cumulative heap usage emulator plugin failed (total usage)!", 
               expectedTotalHeapUsageInMB, fakeCore.getHeapUsageInMB(), 1L);
  // test if the resource plugin shows the expected num calls
  assertEquals("Cumulative heap usage emulator plugin failed (num calls)!", 
               expectedTotalNumCalls, fakeCore.getNumCalls(), 0L);
}
项目：big-c    文件：TestGridmixMemoryEmulation.java    
private static void testEmulationAccuracy(Configuration conf, 
                      FakeHeapUsageEmulatorCore fakeCore,
                      ResourceCalculatorPlugin monitor,
                      ResourceUsageMetrics metrics,
                      TotalHeapUsageEmulatorPlugin heapPlugin,
                      long expectedTotalHeapUsageInMB,
                      long expectedTotalNumCalls)
throws Exception {
  FakeProgressive fakeProgress = new FakeProgressive();
  fakeCore.resetFake();
  heapPlugin.initialize(conf, metrics, monitor, fakeProgress);
  int numLoops = 0;
  while (fakeProgress.getProgress() < 1) {
    ++numLoops;
    float progress = numLoops / 100.0F;
    fakeProgress.setProgress(progress);
    heapPlugin.emulate();
  }

  // test if the resource plugin shows the expected usage
  assertEquals("Cumulative heap usage emulator plugin failed (total usage)!", 
               expectedTotalHeapUsageInMB, fakeCore.getHeapUsageInMB(), 1L);
  // test if the resource plugin shows the expected num calls
  assertEquals("Cumulative heap usage emulator plugin failed (num calls)!", 
               expectedTotalNumCalls, fakeCore.getNumCalls(), 0L);
}
项目：hadoop-2.6.0-cdh5.4.3    文件：TestGridmixMemoryEmulation.java    
private static void testEmulationAccuracy(Configuration conf, 
                      FakeHeapUsageEmulatorCore fakeCore,
                      ResourceCalculatorPlugin monitor,
                      ResourceUsageMetrics metrics,
                      TotalHeapUsageEmulatorPlugin heapPlugin,
                      long expectedTotalHeapUsageInMB,
                      long expectedTotalNumCalls)
throws Exception {
  FakeProgressive fakeProgress = new FakeProgressive();
  fakeCore.resetFake();
  heapPlugin.initialize(conf, metrics, monitor, fakeProgress);
  int numLoops = 0;
  while (fakeProgress.getProgress() < 1) {
    ++numLoops;
    float progress = numLoops / 100.0F;
    fakeProgress.setProgress(progress);
    heapPlugin.emulate();
  }

  // test if the resource plugin shows the expected usage
  assertEquals("Cumulative heap usage emulator plugin failed (total usage)!", 
               expectedTotalHeapUsageInMB, fakeCore.getHeapUsageInMB(), 1L);
  // test if the resource plugin shows the expected num calls
  assertEquals("Cumulative heap usage emulator plugin failed (num calls)!", 
               expectedTotalNumCalls, fakeCore.getNumCalls(), 0L);
}
项目：hadoop-plus    文件：TestGridmixMemoryEmulation.java    
private static void testEmulationAccuracy(Configuration conf, 
                      FakeHeapUsageEmulatorCore fakeCore,
                      ResourceCalculatorPlugin monitor,
                      ResourceUsageMetrics metrics,
                      TotalHeapUsageEmulatorPlugin heapPlugin,
                      long expectedTotalHeapUsageInMB,
                      long expectedTotalNumCalls)
throws Exception {
  FakeProgressive fakeProgress = new FakeProgressive();
  fakeCore.resetFake();
  heapPlugin.initialize(conf, metrics, monitor, fakeProgress);
  int numLoops = 0;
  while (fakeProgress.getProgress() < 1) {
    ++numLoops;
    float progress = numLoops / 100.0F;
    fakeProgress.setProgress(progress);
    heapPlugin.emulate();
  }

  // test if the resource plugin shows the expected usage
  assertEquals("Cumulative heap usage emulator plugin failed (total usage)!", 
               expectedTotalHeapUsageInMB, fakeCore.getHeapUsageInMB(), 1L);
  // test if the resource plugin shows the expected num calls
  assertEquals("Cumulative heap usage emulator plugin failed (num calls)!", 
               expectedTotalNumCalls, fakeCore.getNumCalls(), 0L);
}
项目：hops    文件：TestGridmixMemoryEmulation.java    
private static void testEmulationAccuracy(Configuration conf, 
                      FakeHeapUsageEmulatorCore fakeCore,
                      ResourceCalculatorPlugin monitor,
                      ResourceUsageMetrics metrics,
                      TotalHeapUsageEmulatorPlugin heapPlugin,
                      long expectedTotalHeapUsageInMB,
                      long expectedTotalNumCalls)
throws Exception {
  FakeProgressive fakeProgress = new FakeProgressive();
  fakeCore.resetFake();
  heapPlugin.initialize(conf, metrics, monitor, fakeProgress);
  int numLoops = 0;
  while (fakeProgress.getProgress() < 1) {
    ++numLoops;
    float progress = numLoops / 100.0F;
    fakeProgress.setProgress(progress);
    heapPlugin.emulate();
  }

  // test if the resource plugin shows the expected usage
  assertEquals("Cumulative heap usage emulator plugin failed (total usage)!", 
               expectedTotalHeapUsageInMB, fakeCore.getHeapUsageInMB(), 1L);
  // test if the resource plugin shows the expected num calls
  assertEquals("Cumulative heap usage emulator plugin failed (num calls)!", 
               expectedTotalNumCalls, fakeCore.getNumCalls(), 0L);
}
项目：hadoop-TCP    文件：TestGridmixMemoryEmulation.java    
private static void testEmulationAccuracy(Configuration conf, 
                      FakeHeapUsageEmulatorCore fakeCore,
                      ResourceCalculatorPlugin monitor,
                      ResourceUsageMetrics metrics,
                      TotalHeapUsageEmulatorPlugin heapPlugin,
                      long expectedTotalHeapUsageInMB,
                      long expectedTotalNumCalls)
throws Exception {
  FakeProgressive fakeProgress = new FakeProgressive();
  fakeCore.resetFake();
  heapPlugin.initialize(conf, metrics, monitor, fakeProgress);
  int numLoops = 0;
  while (fakeProgress.getProgress() < 1) {
    ++numLoops;
    float progress = numLoops / 100.0F;
    fakeProgress.setProgress(progress);
    heapPlugin.emulate();
  }

  // test if the resource plugin shows the expected usage
  assertEquals("Cumulative heap usage emulator plugin failed (total usage)!", 
               expectedTotalHeapUsageInMB, fakeCore.getHeapUsageInMB(), 1L);
  // test if the resource plugin shows the expected num calls
  assertEquals("Cumulative heap usage emulator plugin failed (num calls)!", 
               expectedTotalNumCalls, fakeCore.getNumCalls(), 0L);
}
项目：hardfs    文件：TestGridmixMemoryEmulation.java    
private static void testEmulationAccuracy(Configuration conf, 
                      FakeHeapUsageEmulatorCore fakeCore,
                      ResourceCalculatorPlugin monitor,
                      ResourceUsageMetrics metrics,
                      TotalHeapUsageEmulatorPlugin heapPlugin,
                      long expectedTotalHeapUsageInMB,
                      long expectedTotalNumCalls)
throws Exception {
  FakeProgressive fakeProgress = new FakeProgressive();
  fakeCore.resetFake();
  heapPlugin.initialize(conf, metrics, monitor, fakeProgress);
  int numLoops = 0;
  while (fakeProgress.getProgress() < 1) {
    ++numLoops;
    float progress = numLoops / 100.0F;
    fakeProgress.setProgress(progress);
    heapPlugin.emulate();
  }

  // test if the resource plugin shows the expected usage
  assertEquals("Cumulative heap usage emulator plugin failed (total usage)!", 
               expectedTotalHeapUsageInMB, fakeCore.getHeapUsageInMB(), 1L);
  // test if the resource plugin shows the expected num calls
  assertEquals("Cumulative heap usage emulator plugin failed (num calls)!", 
               expectedTotalNumCalls, fakeCore.getNumCalls(), 0L);
}
项目：hadoop-on-lustre2    文件：TestGridmixMemoryEmulation.java    
private static void testEmulationAccuracy(Configuration conf, 
                      FakeHeapUsageEmulatorCore fakeCore,
                      ResourceCalculatorPlugin monitor,
                      ResourceUsageMetrics metrics,
                      TotalHeapUsageEmulatorPlugin heapPlugin,
                      long expectedTotalHeapUsageInMB,
                      long expectedTotalNumCalls)
throws Exception {
  FakeProgressive fakeProgress = new FakeProgressive();
  fakeCore.resetFake();
  heapPlugin.initialize(conf, metrics, monitor, fakeProgress);
  int numLoops = 0;
  while (fakeProgress.getProgress() < 1) {
    ++numLoops;
    float progress = numLoops / 100.0F;
    fakeProgress.setProgress(progress);
    heapPlugin.emulate();
  }

  // test if the resource plugin shows the expected usage
  assertEquals("Cumulative heap usage emulator plugin failed (total usage)!", 
               expectedTotalHeapUsageInMB, fakeCore.getHeapUsageInMB(), 1L);
  // test if the resource plugin shows the expected num calls
  assertEquals("Cumulative heap usage emulator plugin failed (num calls)!", 
               expectedTotalNumCalls, fakeCore.getNumCalls(), 0L);
}
项目：hadoop    文件：TestGridmixMemoryEmulation.java    
private static void testEmulationBoundary(float progress, 
    FakeHeapUsageEmulatorCore fakeCore, FakeProgressive fakeProgress, 
    TotalHeapUsageEmulatorPlugin heapPlugin, long expectedTotalHeapUsageInMB, 
    long expectedTotalNumCalls, String info) throws Exception {
  fakeProgress.setProgress(progress);
  heapPlugin.emulate();
  // test heap usage
  assertEquals("Emulation interval test for heap usage failed " + info + "!", 
               expectedTotalHeapUsageInMB, fakeCore.getHeapUsageInMB(), 0L);
  // test num calls
  assertEquals("Emulation interval test for heap usage failed " + info + "!", 
               expectedTotalNumCalls, fakeCore.getNumCalls(), 0L);
}
项目：aliyun-oss-hadoop-fs    文件：TestGridmixMemoryEmulation.java    
private static void testEmulationBoundary(float progress, 
    FakeHeapUsageEmulatorCore fakeCore, FakeProgressive fakeProgress, 
    TotalHeapUsageEmulatorPlugin heapPlugin, long expectedTotalHeapUsageInMB, 
    long expectedTotalNumCalls, String info) throws Exception {
  fakeProgress.setProgress(progress);
  heapPlugin.emulate();
  // test heap usage
  assertEquals("Emulation interval test for heap usage failed " + info + "!", 
               expectedTotalHeapUsageInMB, fakeCore.getHeapUsageInMB(), 0L);
  // test num calls
  assertEquals("Emulation interval test for heap usage failed " + info + "!", 
               expectedTotalNumCalls, fakeCore.getNumCalls(), 0L);
}
项目：big-c    文件：TestGridmixMemoryEmulation.java    
private static void testEmulationBoundary(float progress, 
    FakeHeapUsageEmulatorCore fakeCore, FakeProgressive fakeProgress, 
    TotalHeapUsageEmulatorPlugin heapPlugin, long expectedTotalHeapUsageInMB, 
    long expectedTotalNumCalls, String info) throws Exception {
  fakeProgress.setProgress(progress);
  heapPlugin.emulate();
  // test heap usage
  assertEquals("Emulation interval test for heap usage failed " + info + "!", 
               expectedTotalHeapUsageInMB, fakeCore.getHeapUsageInMB(), 0L);
  // test num calls
  assertEquals("Emulation interval test for heap usage failed " + info + "!", 
               expectedTotalNumCalls, fakeCore.getNumCalls(), 0L);
}
项目：hadoop-2.6.0-cdh5.4.3    文件：TestGridmixMemoryEmulation.java    
private static void testEmulationBoundary(float progress, 
    FakeHeapUsageEmulatorCore fakeCore, FakeProgressive fakeProgress, 
    TotalHeapUsageEmulatorPlugin heapPlugin, long expectedTotalHeapUsageInMB, 
    long expectedTotalNumCalls, String info) throws Exception {
  fakeProgress.setProgress(progress);
  heapPlugin.emulate();
  // test heap usage
  assertEquals("Emulation interval test for heap usage failed " + info + "!", 
               expectedTotalHeapUsageInMB, fakeCore.getHeapUsageInMB(), 0L);
  // test num calls
  assertEquals("Emulation interval test for heap usage failed " + info + "!", 
               expectedTotalNumCalls, fakeCore.getNumCalls(), 0L);
}
项目：hadoop-plus    文件：TestGridmixMemoryEmulation.java    
private static void testEmulationBoundary(float progress, 
    FakeHeapUsageEmulatorCore fakeCore, FakeProgressive fakeProgress, 
    TotalHeapUsageEmulatorPlugin heapPlugin, long expectedTotalHeapUsageInMB, 
    long expectedTotalNumCalls, String info) throws Exception {
  fakeProgress.setProgress(progress);
  heapPlugin.emulate();
  // test heap usage
  assertEquals("Emulation interval test for heap usage failed " + info + "!", 
               expectedTotalHeapUsageInMB, fakeCore.getHeapUsageInMB(), 0L);
  // test num calls
  assertEquals("Emulation interval test for heap usage failed " + info + "!", 
               expectedTotalNumCalls, fakeCore.getNumCalls(), 0L);
}
项目：hops    文件：TestGridmixMemoryEmulation.java    
private static void testEmulationBoundary(float progress, 
    FakeHeapUsageEmulatorCore fakeCore, FakeProgressive fakeProgress, 
    TotalHeapUsageEmulatorPlugin heapPlugin, long expectedTotalHeapUsageInMB, 
    long expectedTotalNumCalls, String info) throws Exception {
  fakeProgress.setProgress(progress);
  heapPlugin.emulate();
  // test heap usage
  assertEquals("Emulation interval test for heap usage failed " + info + "!", 
               expectedTotalHeapUsageInMB, fakeCore.getHeapUsageInMB(), 0L);
  // test num calls
  assertEquals("Emulation interval test for heap usage failed " + info + "!", 
               expectedTotalNumCalls, fakeCore.getNumCalls(), 0L);
}
项目：hadoop-TCP    文件：TestGridmixMemoryEmulation.java    
private static void testEmulationBoundary(float progress, 
    FakeHeapUsageEmulatorCore fakeCore, FakeProgressive fakeProgress, 
    TotalHeapUsageEmulatorPlugin heapPlugin, long expectedTotalHeapUsageInMB, 
    long expectedTotalNumCalls, String info) throws Exception {
  fakeProgress.setProgress(progress);
  heapPlugin.emulate();
  // test heap usage
  assertEquals("Emulation interval test for heap usage failed " + info + "!", 
               expectedTotalHeapUsageInMB, fakeCore.getHeapUsageInMB(), 0L);
  // test num calls
  assertEquals("Emulation interval test for heap usage failed " + info + "!", 
               expectedTotalNumCalls, fakeCore.getNumCalls(), 0L);
}
项目：hardfs    文件：TestGridmixMemoryEmulation.java    
private static void testEmulationBoundary(float progress, 
    FakeHeapUsageEmulatorCore fakeCore, FakeProgressive fakeProgress, 
    TotalHeapUsageEmulatorPlugin heapPlugin, long expectedTotalHeapUsageInMB, 
    long expectedTotalNumCalls, String info) throws Exception {
  fakeProgress.setProgress(progress);
  heapPlugin.emulate();
  // test heap usage
  assertEquals("Emulation interval test for heap usage failed " + info + "!", 
               expectedTotalHeapUsageInMB, fakeCore.getHeapUsageInMB(), 0L);
  // test num calls
  assertEquals("Emulation interval test for heap usage failed " + info + "!", 
               expectedTotalNumCalls, fakeCore.getNumCalls(), 0L);
}
项目：hadoop-on-lustre2    文件：TestGridmixMemoryEmulation.java    
private static void testEmulationBoundary(float progress, 
    FakeHeapUsageEmulatorCore fakeCore, FakeProgressive fakeProgress, 
    TotalHeapUsageEmulatorPlugin heapPlugin, long expectedTotalHeapUsageInMB, 
    long expectedTotalNumCalls, String info) throws Exception {
  fakeProgress.setProgress(progress);
  heapPlugin.emulate();
  // test heap usage
  assertEquals("Emulation interval test for heap usage failed " + info + "!", 
               expectedTotalHeapUsageInMB, fakeCore.getHeapUsageInMB(), 0L);
  // test num calls
  assertEquals("Emulation interval test for heap usage failed " + info + "!", 
               expectedTotalNumCalls, fakeCore.getNumCalls(), 0L);
}