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

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();
}

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();
}

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();
}

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();
}

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();
}

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();
}

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);
}

protected MonkeyFactory getDefaultMonkeyFactory() {
  // Run with slow deterministic monkey by default
  return MonkeyFactory.getFactory(MonkeyFactory.SLOW_DETERMINISTIC);
}

@Override
protected MonkeyFactory getDefaultMonkeyFactory() {
  return MonkeyFactory.getFactory(MonkeyFactory.CALM);
}

@Override
protected MonkeyFactory getDefaultMonkeyFactory() {
  return MonkeyFactory.getFactory(MonkeyFactory.CALM);
}

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);
}

protected MonkeyFactory getDefaultMonkeyFactory() {
  // Run with slow deterministic monkey by default
  return MonkeyFactory.getFactory(MonkeyFactory.SLOW_DETERMINISTIC);
}

@Override
protected MonkeyFactory getDefaultMonkeyFactory() {
  return MonkeyFactory.getFactory(MonkeyFactory.CALM);
}

@Override
protected MonkeyFactory getDefaultMonkeyFactory() {
  return MonkeyFactory.getFactory(MonkeyFactory.CALM);
}