类org.apache.hadoop.mapreduce.counters.Limits源码实例Demo

下面列出了怎么用org.apache.hadoop.mapreduce.counters.Limits的API类实例代码及写法,或者点击链接到github查看源代码。

源代码1 项目: hadoop   文件: TestCounters.java
private void testMaxCounters(final Counters counters) {
  LOG.info("counters max="+ Limits.getCountersMax());
  for (int i = 0; i < Limits.getCountersMax(); ++i) {
    counters.findCounter("test", "test"+ i);
  }
  setExpected(counters);
  shouldThrow(LimitExceededException.class, new Runnable() {
    public void run() {
      counters.findCounter("test", "bad");
    }
  });
  checkExpected(counters);
}
 
源代码2 项目: hadoop   文件: TestCounters.java
private void testMaxGroups(final Counters counters) {
  LOG.info("counter groups max="+ Limits.getGroupsMax());
  for (int i = 0; i < Limits.getGroupsMax(); ++i) {
    // assuming COUNTERS_MAX > GROUPS_MAX
    counters.findCounter("test"+ i, "test");
  }
  setExpected(counters);
  shouldThrow(LimitExceededException.class, new Runnable() {
    public void run() {
      counters.findCounter("bad", "test");
    }
  });
  checkExpected(counters);
}
 
源代码3 项目: big-c   文件: TestCounters.java
private void testMaxCounters(final Counters counters) {
  LOG.info("counters max="+ Limits.getCountersMax());
  for (int i = 0; i < Limits.getCountersMax(); ++i) {
    counters.findCounter("test", "test"+ i);
  }
  setExpected(counters);
  shouldThrow(LimitExceededException.class, new Runnable() {
    public void run() {
      counters.findCounter("test", "bad");
    }
  });
  checkExpected(counters);
}
 
源代码4 项目: big-c   文件: TestCounters.java
private void testMaxGroups(final Counters counters) {
  LOG.info("counter groups max="+ Limits.getGroupsMax());
  for (int i = 0; i < Limits.getGroupsMax(); ++i) {
    // assuming COUNTERS_MAX > GROUPS_MAX
    counters.findCounter("test"+ i, "test");
  }
  setExpected(counters);
  shouldThrow(LimitExceededException.class, new Runnable() {
    public void run() {
      counters.findCounter("bad", "test");
    }
  });
  checkExpected(counters);
}
 
源代码5 项目: hadoop   文件: Counters.java
GenericGroup(String name, String displayName, Limits limits) {
  super(name, displayName, limits);
}
 
源代码6 项目: hadoop   文件: Counters.java
@Override
protected Group newGenericGroup(String name, String displayName,
                                Limits limits) {
  return new Group(new GenericGroup(name, displayName, limits));
}
 
源代码7 项目: hadoop   文件: Counters.java
GenericGroup(String name, String displayName, Limits limits) {
  super(name, displayName, limits);
}
 
源代码8 项目: hadoop   文件: Counters.java
@Override
protected CounterGroup newGenericGroup(String name, String displayName,
                                       Limits limits) {
  return new GenericGroup(name, displayName, limits);
}
 
源代码9 项目: big-c   文件: Counters.java
GenericGroup(String name, String displayName, Limits limits) {
  super(name, displayName, limits);
}
 
源代码10 项目: big-c   文件: Counters.java
@Override
protected Group newGenericGroup(String name, String displayName,
                                Limits limits) {
  return new Group(new GenericGroup(name, displayName, limits));
}
 
源代码11 项目: big-c   文件: Counters.java
GenericGroup(String name, String displayName, Limits limits) {
  super(name, displayName, limits);
}
 
源代码12 项目: big-c   文件: Counters.java
@Override
protected CounterGroup newGenericGroup(String name, String displayName,
                                       Limits limits) {
  return new GenericGroup(name, displayName, limits);
}
 
源代码13 项目: ignite   文件: HadoopMapReduceCounters.java
/** {@inheritDoc} */
@Override public Limits limits() {
    return null;
}
 
 类方法
 同包方法