Java 类org.apache.hadoop.hbase.regionserver.RegionServerAccounting 实例源码

项目:LCIndex-HBase-0.94.16    文件:OpenRegionHandler.java   
/**
 * @return Instance of HRegion if successful open else null.
 */
HRegion openRegion() {
  HRegion region = null;
  try {
    // Instantiate the region.  This also periodically tickles our zk OPENING
    // state so master doesn't timeout this region in transition.
    region = HRegion.openHRegion(this.regionInfo, this.htd,
        this.rsServices.getWAL(this.regionInfo), 
        this.server.getConfiguration(),
        this.rsServices,
      new CancelableProgressable() {
        public boolean progress() {
          // We may lose the znode ownership during the open.  Currently its
          // too hard interrupting ongoing region open.  Just let it complete
          // and check we still have the znode after region open.
          return tickleOpening("open_region_progress");
        }
      });
  } catch (Throwable t) {
    // We failed open. Our caller will see the 'null' return value
    // and transition the node back to FAILED_OPEN. If that fails,
    // we rely on the Timeout Monitor in the master to reassign.
    LOG.error(
        "Failed open of region=" + this.regionInfo.getRegionNameAsString()
            + ", starting to roll back the global memstore size.", t);
    // Decrease the global memstore size.
    if (this.rsServices != null) {
      RegionServerAccounting rsAccounting =
        this.rsServices.getRegionServerAccounting();
      if (rsAccounting != null) {
        rsAccounting.rollbackRegionReplayEditsSize(this.regionInfo.getRegionName());
      }
    }
  }
  return region;
}
项目:HIndex    文件:OpenRegionHandler.java   
/**
 * @return Instance of HRegion if successful open else null.
 */
HRegion openRegion() {
  HRegion region = null;
  try {
    // Instantiate the region.  This also periodically tickles our zk OPENING
    // state so master doesn't timeout this region in transition.
    region = HRegion.openHRegion(this.regionInfo, this.htd,
        this.rsServices.getWAL(this.regionInfo),
        this.server.getConfiguration(),
        this.rsServices,
      new CancelableProgressable() {
        public boolean progress() {
          // We may lose the znode ownership during the open.  Currently its
          // too hard interrupting ongoing region open.  Just let it complete
          // and check we still have the znode after region open.
          return tickleOpening("open_region_progress");
        }
      });
  } catch (Throwable t) {
    // We failed open. Our caller will see the 'null' return value
    // and transition the node back to FAILED_OPEN. If that fails,
    // we rely on the Timeout Monitor in the master to reassign.
    LOG.error(
        "Failed open of region=" + this.regionInfo.getRegionNameAsString()
            + ", starting to roll back the global memstore size.", t);
    // Decrease the global memstore size.
    if (this.rsServices != null) {
      RegionServerAccounting rsAccounting =
        this.rsServices.getRegionServerAccounting();
      if (rsAccounting != null) {
        rsAccounting.rollbackRegionReplayEditsSize(this.regionInfo.getRegionName());
      }
    }
  }
  return region;
}
项目:IRIndex    文件:OpenRegionHandler.java   
/**
 * @return Instance of HRegion if successful open else null.
 */
HRegion openRegion() {
  HRegion region = null;
  try {
    // Instantiate the region.  This also periodically tickles our zk OPENING
    // state so master doesn't timeout this region in transition.
    region = HRegion.openHRegion(this.regionInfo, this.htd,
        this.rsServices.getWAL(this.regionInfo), 
        this.server.getConfiguration(),
        this.rsServices,
      new CancelableProgressable() {
        public boolean progress() {
          // We may lose the znode ownership during the open.  Currently its
          // too hard interrupting ongoing region open.  Just let it complete
          // and check we still have the znode after region open.
          return tickleOpening("open_region_progress");
        }
      });
  } catch (Throwable t) {
    // We failed open. Our caller will see the 'null' return value
    // and transition the node back to FAILED_OPEN. If that fails,
    // we rely on the Timeout Monitor in the master to reassign.
    LOG.error(
        "Failed open of region=" + this.regionInfo.getRegionNameAsString()
            + ", starting to roll back the global memstore size.", t);
    // Decrease the global memstore size.
    if (this.rsServices != null) {
      RegionServerAccounting rsAccounting =
        this.rsServices.getRegionServerAccounting();
      if (rsAccounting != null) {
        rsAccounting.rollbackRegionReplayEditsSize(this.regionInfo.getRegionName());
      }
    }
  }
  return region;
}
项目:hbase    文件:OpenRegionHandler.java   
/**
 * @return Instance of HRegion if successful open else null.
 */
HRegion openRegion() {
  HRegion region = null;
  try {
    // Instantiate the region.  This also periodically tickles OPENING
    // state so master doesn't timeout this region in transition.
    region = HRegion.openHRegion(this.regionInfo, this.htd,
      this.rsServices.getWAL(this.regionInfo),
      this.server.getConfiguration(),
      this.rsServices,
      new CancelableProgressable() {
        @Override
        public boolean progress() {
          if (!isRegionStillOpening()) {
            LOG.warn("Open region aborted since it isn't opening any more");
            return false;
          }
          return true;
        }
      });
  } catch (Throwable t) {
    // We failed open. Our caller will see the 'null' return value
    // and transition the node back to FAILED_OPEN. If that fails,
    // we rely on the Timeout Monitor in the master to reassign.
    LOG.error(
        "Failed open of region=" + this.regionInfo.getRegionNameAsString()
            + ", starting to roll back the global memstore size.", t);
    // Decrease the global memstore size.
    if (this.rsServices != null) {
      RegionServerAccounting rsAccounting =
        this.rsServices.getRegionServerAccounting();
      if (rsAccounting != null) {
        rsAccounting.rollbackRegionReplayEditsSize(this.regionInfo.getRegionName());
      }
    }
  }
  return region;
}
项目:PyroDB    文件:OpenRegionHandler.java   
/**
 * @return Instance of HRegion if successful open else null.
 */
HRegion openRegion() {
  HRegion region = null;
  try {
    // Instantiate the region.  This also periodically tickles our zk OPENING
    // state so master doesn't timeout this region in transition.
    region = HRegion.openHRegion(this.regionInfo, this.htd,
        this.rsServices.getWAL(this.regionInfo),
        this.server.getConfiguration(),
        this.rsServices,
      new CancelableProgressable() {
        public boolean progress() {
          // We may lose the znode ownership during the open.  Currently its
          // too hard interrupting ongoing region open.  Just let it complete
          // and check we still have the znode after region open.
          return tickleOpening("open_region_progress");
        }
      });
  } catch (Throwable t) {
    // We failed open. Our caller will see the 'null' return value
    // and transition the node back to FAILED_OPEN. If that fails,
    // we rely on the Timeout Monitor in the master to reassign.
    LOG.error(
        "Failed open of region=" + this.regionInfo.getRegionNameAsString()
            + ", starting to roll back the global memstore size.", t);
    // Decrease the global memstore size.
    if (this.rsServices != null) {
      RegionServerAccounting rsAccounting =
        this.rsServices.getRegionServerAccounting();
      if (rsAccounting != null) {
        rsAccounting.rollbackRegionReplayEditsSize(this.regionInfo.getRegionName());
      }
    }
  }
  return region;
}
项目:c5    文件:OpenRegionHandler.java   
/**
 * @return Instance of HRegion if successful open else null.
 */
HRegion openRegion() {
  HRegion region = null;
  try {
    // Instantiate the region.  This also periodically tickles our zk OPENING
    // state so master doesn't timeout this region in transition.
    region = HRegion.openHRegion(this.regionInfo, this.htd,
        this.rsServices.getWAL(this.regionInfo), 
        this.server.getConfiguration(),
        this.rsServices,
      new CancelableProgressable() {
        public boolean progress() {
          // We may lose the znode ownership during the open.  Currently its
          // too hard interrupting ongoing region open.  Just let it complete
          // and check we still have the znode after region open.
          return tickleOpening("open_region_progress");
        }
      });
  } catch (Throwable t) {
    // We failed open. Our caller will see the 'null' return value
    // and transition the node back to FAILED_OPEN. If that fails,
    // we rely on the Timeout Monitor in the master to reassign.
    LOG.error(
        "Failed open of region=" + this.regionInfo.getRegionNameAsString()
            + ", starting to roll back the global memstore size.", t);
    // Decrease the global memstore size.
    if (this.rsServices != null) {
      RegionServerAccounting rsAccounting =
        this.rsServices.getRegionServerAccounting();
      if (rsAccounting != null) {
        rsAccounting.rollbackRegionReplayEditsSize(this.regionInfo.getRegionName());
      }
    }
  }
  return region;
}
项目:HBase-Research    文件:OpenRegionHandler.java   
/**
 * @return Instance of HRegion if successful open else null.
 */
HRegion openRegion() {
  HRegion region = null;
  try {
    // Instantiate the region.  This also periodically tickles our zk OPENING
    // state so master doesn't timeout this region in transition.
    region = HRegion.openHRegion(this.regionInfo, this.htd,
        this.rsServices.getWAL(this.regionInfo), 
        this.server.getConfiguration(),
        this.rsServices,
      new CancelableProgressable() {
        public boolean progress() {
          // We may lose the znode ownership during the open.  Currently its
          // too hard interrupting ongoing region open.  Just let it complete
          // and check we still have the znode after region open.
          return tickleOpening("open_region_progress");
        }
      });
  } catch (Throwable t) {
    // We failed open. Our caller will see the 'null' return value
    // and transition the node back to FAILED_OPEN. If that fails,
    // we rely on the Timeout Monitor in the master to reassign.
    LOG.error(
        "Failed open of region=" + this.regionInfo.getRegionNameAsString()
            + ", starting to roll back the global memstore size.", t);
    // Decrease the global memstore size.
    if (this.rsServices != null) {
      RegionServerAccounting rsAccounting =
        this.rsServices.getRegionServerAccounting();
      if (rsAccounting != null) {
        rsAccounting.rollbackRegionReplayEditsSize(this.regionInfo.getRegionName());
      }
    }
  }
  return region;
}
项目:hbase-0.94.8-qod    文件:OpenRegionHandler.java   
/**
 * @return Instance of HRegion if successful open else null.
 */
HRegion openRegion() {
  HRegion region = null;
  try {
    // Instantiate the region.  This also periodically tickles our zk OPENING
    // state so master doesn't timeout this region in transition.
    region = HRegion.openHRegion(this.regionInfo, this.htd,
        this.rsServices.getWAL(this.regionInfo), 
        this.server.getConfiguration(),
        this.rsServices,
      new CancelableProgressable() {
        public boolean progress() {
          // We may lose the znode ownership during the open.  Currently its
          // too hard interrupting ongoing region open.  Just let it complete
          // and check we still have the znode after region open.
          return tickleOpening("open_region_progress");
        }
      });
  } catch (Throwable t) {
    // We failed open. Our caller will see the 'null' return value
    // and transition the node back to FAILED_OPEN. If that fails,
    // we rely on the Timeout Monitor in the master to reassign.
    LOG.error(
        "Failed open of region=" + this.regionInfo.getRegionNameAsString()
            + ", starting to roll back the global memstore size.", t);
    // Decrease the global memstore size.
    if (this.rsServices != null) {
      RegionServerAccounting rsAccounting =
        this.rsServices.getRegionServerAccounting();
      if (rsAccounting != null) {
        rsAccounting.rollbackRegionReplayEditsSize(this.regionInfo.getRegionName());
      }
    }
  }
  return region;
}
项目:hbase-0.94.8-qod    文件:OpenRegionHandler.java   
/**
 * @return Instance of HRegion if successful open else null.
 */
HRegion openRegion() {
  HRegion region = null;
  try {
    // Instantiate the region.  This also periodically tickles our zk OPENING
    // state so master doesn't timeout this region in transition.
    region = HRegion.openHRegion(this.regionInfo, this.htd,
        this.rsServices.getWAL(this.regionInfo), 
        this.server.getConfiguration(),
        this.rsServices,
      new CancelableProgressable() {
        public boolean progress() {
          // We may lose the znode ownership during the open.  Currently its
          // too hard interrupting ongoing region open.  Just let it complete
          // and check we still have the znode after region open.
          return tickleOpening("open_region_progress");
        }
      });
  } catch (Throwable t) {
    // We failed open. Our caller will see the 'null' return value
    // and transition the node back to FAILED_OPEN. If that fails,
    // we rely on the Timeout Monitor in the master to reassign.
    LOG.error(
        "Failed open of region=" + this.regionInfo.getRegionNameAsString()
            + ", starting to roll back the global memstore size.", t);
    // Decrease the global memstore size.
    if (this.rsServices != null) {
      RegionServerAccounting rsAccounting =
        this.rsServices.getRegionServerAccounting();
      if (rsAccounting != null) {
        rsAccounting.rollbackRegionReplayEditsSize(this.regionInfo.getRegionName());
      }
    }
  }
  return region;
}
项目:DominoHBase    文件:OpenRegionHandler.java   
/**
 * @return Instance of HRegion if successful open else null.
 */
HRegion openRegion() {
  HRegion region = null;
  try {
    // Instantiate the region.  This also periodically tickles our zk OPENING
    // state so master doesn't timeout this region in transition.
    region = HRegion.openHRegion(this.regionInfo, this.htd,
        this.rsServices.getWAL(this.regionInfo), 
        this.server.getConfiguration(),
        this.rsServices,
      new CancelableProgressable() {
        public boolean progress() {
          // We may lose the znode ownership during the open.  Currently its
          // too hard interrupting ongoing region open.  Just let it complete
          // and check we still have the znode after region open.
          return tickleOpening("open_region_progress");
        }
      });
  } catch (Throwable t) {
    // We failed open. Our caller will see the 'null' return value
    // and transition the node back to FAILED_OPEN. If that fails,
    // we rely on the Timeout Monitor in the master to reassign.
    LOG.error(
        "Failed open of region=" + this.regionInfo.getRegionNameAsString()
            + ", starting to roll back the global memstore size.", t);
    // Decrease the global memstore size.
    if (this.rsServices != null) {
      RegionServerAccounting rsAccounting =
        this.rsServices.getRegionServerAccounting();
      if (rsAccounting != null) {
        rsAccounting.rollbackRegionReplayEditsSize(this.regionInfo.getRegionName());
      }
    }
  }
  return region;
}
项目:hindex    文件:OpenRegionHandler.java   
/**
 * @return Instance of HRegion if successful open else null.
 */
HRegion openRegion() {
  HRegion region = null;
  try {
    // Instantiate the region.  This also periodically tickles our zk OPENING
    // state so master doesn't timeout this region in transition.
    region = HRegion.openHRegion(this.regionInfo, this.htd,
        this.rsServices.getWAL(this.regionInfo), 
        this.server.getConfiguration(),
        this.rsServices,
      new CancelableProgressable() {
        public boolean progress() {
          // We may lose the znode ownership during the open.  Currently its
          // too hard interrupting ongoing region open.  Just let it complete
          // and check we still have the znode after region open.
          return tickleOpening("open_region_progress");
        }
      });
  } catch (Throwable t) {
    // We failed open. Our caller will see the 'null' return value
    // and transition the node back to FAILED_OPEN. If that fails,
    // we rely on the Timeout Monitor in the master to reassign.
    LOG.error(
        "Failed open of region=" + this.regionInfo.getRegionNameAsString()
            + ", starting to roll back the global memstore size.", t);
    // Decrease the global memstore size.
    if (this.rsServices != null) {
      RegionServerAccounting rsAccounting =
        this.rsServices.getRegionServerAccounting();
      if (rsAccounting != null) {
        rsAccounting.rollbackRegionReplayEditsSize(this.regionInfo.getRegionName());
      }
    }
  }
  return region;
}
项目:ditb    文件:OpenRegionHandler.java   
/**
 * @return Instance of HRegion if successful open else null.
 */
HRegion openRegion() {
  HRegion region = null;
  try {
    // Instantiate the region.  This also periodically tickles OPENING
    // state so master doesn't timeout this region in transition.
    region = HRegion.openHRegion(this.regionInfo, this.htd,
      this.rsServices.getWAL(this.regionInfo),
      this.server.getConfiguration(),
      this.rsServices,
      new CancelableProgressable() {
        @Override
        public boolean progress() {
          if (useZKForAssignment) {
            // if tickle failed, we need to cancel opening region.
            return coordination.tickleOpening(ord, regionInfo,
              rsServices, "open_region_progress");
          }
          if (!isRegionStillOpening()) {
            LOG.warn("Open region aborted since it isn't opening any more");
            return false;
          }
          return true;
        }
      });
  } catch (Throwable t) {
    // We failed open. Our caller will see the 'null' return value
    // and transition the node back to FAILED_OPEN. If that fails,
    // we rely on the Timeout Monitor in the master to reassign.
    LOG.error(
        "Failed open of region=" + this.regionInfo.getRegionNameAsString()
            + ", starting to roll back the global memstore size.", t);
    // Decrease the global memstore size.
    if (this.rsServices != null) {
      RegionServerAccounting rsAccounting =
        this.rsServices.getRegionServerAccounting();
      if (rsAccounting != null) {
        rsAccounting.rollbackRegionReplayEditsSize(this.regionInfo.getRegionName());
      }
    }
  }
  return region;
}
项目:ditb    文件:MockRegionServer.java   
@Override
public RegionServerAccounting getRegionServerAccounting() {
  // TODO Auto-generated method stub
  return null;
}
项目:ditb    文件:MockRegionServerServices.java   
public RegionServerAccounting getRegionServerAccounting() {
  return null;
}
项目:incubator-tephra    文件:TransactionProcessorTest.java   
@Override
public RegionServerAccounting getRegionServerAccounting() {
  return null;
}
项目:incubator-tephra    文件:TransactionProcessorTest.java   
@Override
public RegionServerAccounting getRegionServerAccounting() {
  return null;
}
项目:LCIndex-HBase-0.94.16    文件:MockRegionServerServices.java   
public RegionServerAccounting getRegionServerAccounting() {
  return null;
}
项目:pbase    文件:OpenRegionHandler.java   
/**
 * @return Instance of HRegion if successful open else null.
 */
HRegion openRegion() {
  HRegion region = null;
  try {
    // Instantiate the region.  This also periodically tickles OPENING
    // state so master doesn't timeout this region in transition.
    region = HRegion.openHRegion(this.regionInfo, this.htd,
      this.rsServices.getWAL(this.regionInfo),
      this.server.getConfiguration(),
      this.rsServices,
      new CancelableProgressable() {
        public boolean progress() {
          if (useZKForAssignment) {
            // if tickle failed, we need to cancel opening region.
            return coordination.tickleOpening(ord, regionInfo,
              rsServices, "open_region_progress");
          }
          if (!isRegionStillOpening()) {
            LOG.warn("Open region aborted since it isn't opening any more");
            return false;
          }
          return true;
        }
      });
  } catch (Throwable t) {
    // We failed open. Our caller will see the 'null' return value
    // and transition the node back to FAILED_OPEN. If that fails,
    // we rely on the Timeout Monitor in the master to reassign.
    LOG.error(
        "Failed open of region=" + this.regionInfo.getRegionNameAsString()
            + ", starting to roll back the global memstore size.", t);
    // Decrease the global memstore size.
    if (this.rsServices != null) {
      RegionServerAccounting rsAccounting =
        this.rsServices.getRegionServerAccounting();
      if (rsAccounting != null) {
        rsAccounting.rollbackRegionReplayEditsSize(this.regionInfo.getRegionName());
      }
    }
  }
  return region;
}
项目:pbase    文件:MockRegionServer.java   
@Override
public RegionServerAccounting getRegionServerAccounting() {
  // TODO Auto-generated method stub
  return null;
}
项目:pbase    文件:MockRegionServerServices.java   
public RegionServerAccounting getRegionServerAccounting() {
  return null;
}
项目:HIndex    文件:MockRegionServer.java   
@Override
public RegionServerAccounting getRegionServerAccounting() {
  // TODO Auto-generated method stub
  return null;
}
项目:HIndex    文件:MockRegionServerServices.java   
public RegionServerAccounting getRegionServerAccounting() {
  return null;
}
项目:IRIndex    文件:MockRegionServerServices.java   
public RegionServerAccounting getRegionServerAccounting() {
  return null;
}
项目:hbase    文件:MockRegionServer.java   
@Override
public RegionServerAccounting getRegionServerAccounting() {
  return null;
}
项目:hbase    文件:MockRegionServerServices.java   
@Override
public RegionServerAccounting getRegionServerAccounting() {
  return null;
}
项目:PyroDB    文件:MockRegionServer.java   
@Override
public RegionServerAccounting getRegionServerAccounting() {
  // TODO Auto-generated method stub
  return null;
}
项目:PyroDB    文件:MockRegionServerServices.java   
public RegionServerAccounting getRegionServerAccounting() {
  return null;
}
项目:c5    文件:HRegionServicesBridge.java   
@Override
public RegionServerAccounting getRegionServerAccounting() {
  return new RegionServerAccounting();
}
项目:c5    文件:MockRegionServer.java   
@Override
public RegionServerAccounting getRegionServerAccounting() {
  // TODO Auto-generated method stub
  return null;
}
项目:c5    文件:MockRegionServerServices.java   
public RegionServerAccounting getRegionServerAccounting() {
  return null;
}
项目:HBase-Research    文件:MockRegionServerServices.java   
public RegionServerAccounting getRegionServerAccounting() {
  return null;
}
项目:hbase-0.94.8-qod    文件:MockRegionServerServices.java   
public RegionServerAccounting getRegionServerAccounting() {
  return null;
}
项目:hbase-0.94.8-qod    文件:MockRegionServerServices.java   
public RegionServerAccounting getRegionServerAccounting() {
  return null;
}
项目:DominoHBase    文件:MockRegionServer.java   
@Override
public RegionServerAccounting getRegionServerAccounting() {
  // TODO Auto-generated method stub
  return null;
}
项目:DominoHBase    文件:MockRegionServerServices.java   
public RegionServerAccounting getRegionServerAccounting() {
  return null;
}
项目:hindex    文件:MockRegionServerServices.java   
public RegionServerAccounting getRegionServerAccounting() {
  return null;
}