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