Java 类org.apache.hadoop.hbase.chaos.actions.RestartRsHoldingTableAction 实例源码

项目：HIndex 文件：IntegrationTestMTTR.java

private static void setupActions() throws IOException {
  // Set up the action that will restart a region server holding a region from our table
  // because this table should only have one region we should be good.
  restartRSAction = new RestartRsHoldingTableAction(sleepTime, tableName.getNameAsString());

  // Set up the action that will kill the region holding meta.
  restartMetaAction = new RestartRsHoldingMetaAction(sleepTime);

  // Set up the action that will move the regions of our table.
  moveRegionAction = new MoveRegionsOfTableAction(sleepTime, tableName.getNameAsString());

  // Kill the master
  restartMasterAction = new RestartActiveMasterAction(1000);

  // Give the action the access to the cluster.
  Action.ActionContext actionContext = new Action.ActionContext(util);
  restartRSAction.init(actionContext);
  restartMetaAction.init(actionContext);
  moveRegionAction.init(actionContext);
  restartMasterAction.init(actionContext);
}

项目：PyroDB 文件：IntegrationTestMTTR.java

private static void setupActions() throws IOException {
  // Set up the action that will restart a region server holding a region from our table
  // because this table should only have one region we should be good.
  restartRSAction = new RestartRsHoldingTableAction(sleepTime, tableName.getNameAsString());

  // Set up the action that will kill the region holding meta.
  restartMetaAction = new RestartRsHoldingMetaAction(sleepTime);

  // Set up the action that will move the regions of our table.
  moveRegionAction = new MoveRegionsOfTableAction(sleepTime, tableName.getNameAsString());

  // Kill the master
  restartMasterAction = new RestartActiveMasterAction(1000);

  // Give the action the access to the cluster.
  Action.ActionContext actionContext = new Action.ActionContext(util);
  restartRSAction.init(actionContext);
  restartMetaAction.init(actionContext);
  moveRegionAction.init(actionContext);
  restartMasterAction.init(actionContext);
}

项目：ditb 文件：IntegrationTestMTTR.java

private static void setupActions() throws IOException {
  // allow a little more time for RS restart actions because RS start depends on having a master
  // to report to and the master is also being monkeyed.
  util.getConfiguration().setLong(Action.START_RS_TIMEOUT_KEY, 3 * 60 * 1000);

  // Set up the action that will restart a region server holding a region from our table
  // because this table should only have one region we should be good.
  restartRSAction = new RestartRsHoldingTableAction(sleepTime, tableName.getNameAsString());

  // Set up the action that will kill the region holding meta.
  restartMetaAction = new RestartRsHoldingMetaAction(sleepTime);

  // Set up the action that will move the regions of meta.
  moveMetaRegionsAction = new MoveRegionsOfTableAction(sleepTime,
      MonkeyConstants.DEFAULT_MOVE_REGIONS_MAX_TIME, TableName.META_TABLE_NAME);

  // Set up the action that will move the regions of our table.
  moveRegionAction = new MoveRegionsOfTableAction(sleepTime,
      MonkeyConstants.DEFAULT_MOVE_REGIONS_MAX_TIME, tableName);

  // Kill the master
  restartMasterAction = new RestartActiveMasterAction(1000);

  // Give the action the access to the cluster.
  Action.ActionContext actionContext = new Action.ActionContext(util);
  restartRSAction.init(actionContext);
  restartMetaAction.init(actionContext);
  moveMetaRegionsAction.init(actionContext);
  moveRegionAction.init(actionContext);
  restartMasterAction.init(actionContext);
}

项目：hbase 文件：IntegrationTestMTTR.java

private static void setupActions() throws IOException {
  // allow a little more time for RS restart actions because RS start depends on having a master
  // to report to and the master is also being monkeyed.
  util.getConfiguration().setLong(Action.START_RS_TIMEOUT_KEY, 3 * 60 * 1000);

  // Set up the action that will restart a region server holding a region from our table
  // because this table should only have one region we should be good.
  restartRSAction = new RestartRsHoldingTableAction(sleepTime,
      util.getConnection().getRegionLocator(tableName));

  // Set up the action that will kill the region holding meta.
  restartMetaAction = new RestartRsHoldingMetaAction(sleepTime);

  // Set up the action that will move the regions of meta.
  moveMetaRegionsAction = new MoveRegionsOfTableAction(sleepTime,
      MonkeyConstants.DEFAULT_MOVE_REGIONS_MAX_TIME, TableName.META_TABLE_NAME);

  // Set up the action that will move the regions of our table.
  moveRegionAction = new MoveRegionsOfTableAction(sleepTime,
      MonkeyConstants.DEFAULT_MOVE_REGIONS_MAX_TIME, tableName);

  // Kill the master
  restartMasterAction = new RestartActiveMasterAction(1000);

  // Give the action the access to the cluster.
  Action.ActionContext actionContext = new Action.ActionContext(util);
  restartRSAction.init(actionContext);
  restartMetaAction.init(actionContext);
  moveMetaRegionsAction.init(actionContext);
  moveRegionAction.init(actionContext);
  restartMasterAction.init(actionContext);
}