Java 类org.apache.hadoop.hbase.chaos.factories.MonkeyFactory 实例源码

项目:ditb    文件:IntegrationTestBase.java   
public void setUpMonkey() throws Exception {
  util = getTestingUtil(getConf());
  MonkeyFactory fact = MonkeyFactory.getFactory(monkeyToUse);
  if (fact == null) {
    fact = getDefaultMonkeyFactory();
  }
  monkey = fact.setUtil(util)
               .setTableName(getTablename())
               .setProperties(monkeyProps)
               .setColumnFamilies(getColumnFamilies()).build();
  startMonkey();
}
项目:ditb    文件:ChaosMonkeyRunner.java   
public void getAndStartMonkey() throws Exception {
  util = getTestingUtil(getConf());
  MonkeyFactory fact = MonkeyFactory.getFactory(monkeyToUse);
  if (fact == null) {
    fact = getDefaultMonkeyFactory();
  }
  monkey =
      fact.setUtil(util).setTableName(getTablename()).setProperties(monkeyProps)
          .setColumnFamilies(getColumnFamilies()).build();
  monkey.start();
}
项目:HIndex    文件:IntegrationTestBase.java   
public void setUpMonkey() throws Exception {
  util = getTestingUtil(getConf());
  MonkeyFactory fact = MonkeyFactory.getFactory(monkeyToUse);
  if (fact == null) {
    // Run with no monkey in distributed context, with real monkey in local test context.
    fact = MonkeyFactory.getFactory(
        util.isDistributedCluster() ? MonkeyFactory.CALM : MonkeyFactory.SLOW_DETERMINISTIC);
  }
  monkey = fact.setUtil(util)
               .setTableName(getTablename())
               .setColumnFamilies(getColumnFamilies()).build();
  monkey.start();
}
项目:hbase    文件:IntegrationTestBase.java   
public void setUpMonkey() throws Exception {
  util = getTestingUtil(getConf());
  MonkeyFactory fact = MonkeyFactory.getFactory(monkeyToUse);
  if (fact == null) {
    fact = getDefaultMonkeyFactory();
  }
  monkey = fact.setUtil(util)
               .setTableName(getTablename())
               .setProperties(monkeyProps)
               .setColumnFamilies(getColumnFamilies()).build();
  startMonkey();
}
项目:hbase    文件:ChaosMonkeyRunner.java   
public void getAndStartMonkey() throws Exception {
  util = getTestingUtil(getConf());
  MonkeyFactory fact = MonkeyFactory.getFactory(monkeyToUse);
  if (fact == null) {
    fact = getDefaultMonkeyFactory();
  }
  monkey =
      fact.setUtil(util).setTableName(getTablename()).setProperties(monkeyProps)
          .setColumnFamilies(getColumnFamilies()).build();
  monkey.start();
}
项目:PyroDB    文件:IntegrationTestBase.java   
public void setUpMonkey() throws Exception {
  util = getTestingUtil(getConf());
  MonkeyFactory fact = MonkeyFactory.getFactory(monkeyToUse);
  if (fact == null) {
    // Run with no monkey in distributed context, with real monkey in local test context.
    fact = MonkeyFactory.getFactory(
        util.isDistributedCluster() ? MonkeyFactory.CALM : MonkeyFactory.SLOW_DETERMINISTIC);
  }
  monkey = fact.setUtil(util)
               .setTableName(getTablename())
               .setColumnFamilies(getColumnFamilies()).build();
  monkey.start();
}
项目:ditb    文件:IntegrationTestBase.java   
protected MonkeyFactory getDefaultMonkeyFactory() {
  // Run with no monkey in distributed context, with real monkey in local test context.
  return MonkeyFactory.getFactory(
    util.isDistributedCluster() ? MonkeyFactory.CALM : MonkeyFactory.SLOW_DETERMINISTIC);
}
项目:ditb    文件:ChaosMonkeyRunner.java   
protected MonkeyFactory getDefaultMonkeyFactory() {
  // Run with slow deterministic monkey by default
  return MonkeyFactory.getFactory(MonkeyFactory.SLOW_DETERMINISTIC);
}
项目:ditb    文件:IntegrationTestBigLinkedListWithVisibility.java   
@Override
protected MonkeyFactory getDefaultMonkeyFactory() {
  return MonkeyFactory.getFactory(MonkeyFactory.CALM);
}
项目:ditb    文件:IntegrationTestTimeBoundedRequestsWithRegionReplicas.java   
@Override
protected MonkeyFactory getDefaultMonkeyFactory() {
  return MonkeyFactory.getFactory(MonkeyFactory.CALM);
}
项目:hbase    文件:IntegrationTestBase.java   
protected MonkeyFactory getDefaultMonkeyFactory() {
  // Run with no monkey in distributed context, with real monkey in local test context.
  return MonkeyFactory.getFactory(
    util.isDistributedCluster() ? MonkeyFactory.CALM : MonkeyFactory.SLOW_DETERMINISTIC);
}
项目:hbase    文件:ChaosMonkeyRunner.java   
protected MonkeyFactory getDefaultMonkeyFactory() {
  // Run with slow deterministic monkey by default
  return MonkeyFactory.getFactory(MonkeyFactory.SLOW_DETERMINISTIC);
}
项目:hbase    文件:IntegrationTestBigLinkedListWithVisibility.java   
@Override
protected MonkeyFactory getDefaultMonkeyFactory() {
  return MonkeyFactory.getFactory(MonkeyFactory.CALM);
}
项目:hbase    文件:IntegrationTestTimeBoundedRequestsWithRegionReplicas.java   
@Override
protected MonkeyFactory getDefaultMonkeyFactory() {
  return MonkeyFactory.getFactory(MonkeyFactory.CALM);
}