1. 包列表
  2. 类列表
  3. org.apache.hadoop.hbase.regionserver.RegionServerAccounting

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