本文整理了Java中org.apache.hadoop.hbase.regionserver.Region.startRegionOperation方法的一些代码示例，展示了Region.startRegionOperation的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Region.startRegionOperation方法的具体详情如下：
包路径：org.apache.hadoop.hbase.regionserver.Region
类名称：Region
方法名：startRegionOperation

Region.startRegionOperation介绍

[英]This method needs to be called before any public call that reads or modifies data. Acquires a read lock and checks if the region is closing or closed.

#closeRegionOperation MUST then always be called after the operation has completed, whether it succeeded or failed.
[中]在任何读取或修改数据的公共调用之前，都需要调用此方法。获取读取锁并检查区域是否关闭。
#然后，无论操作成功或失败，都必须在操作完成后调用closeRegionOperation。

代码示例

代码示例来源：origin: apache/hbase

RegionOp(final Region region) throws IOException {
 this.region = region;
 region.startRegionOperation();
}

代码示例来源：origin: apache/phoenix

private long collectStatsInternal() throws IOException {
  long startTime = EnvironmentEdgeManager.currentTimeMillis();
  region.startRegionOperation();
  boolean hasMore = false;
  boolean noErrors = false;

代码示例来源：origin: org.apache.hbase/hbase-endpoint

RegionOp(final Region region) throws IOException {
 this.region = region;
 region.startRegionOperation();
}

代码示例来源：origin: com.aliyun.hbase/alihbase-endpoint

RegionOp(final Region region) throws IOException {
 this.region = region;
 region.startRegionOperation();
}

代码示例来源：origin: apache/phoenix

final Tuple firstTuple;
final Region region = getRegion();
region.startRegionOperation();
try {
 Tuple tuple = iterator.next();

代码示例来源：origin: apache/phoenix

boolean acquiredLock = false;
try {
  region.startRegionOperation();
  acquiredLock = true;
  synchronized (scanner) {

代码示例来源：origin: apache/phoenix

boolean acquiredLock = false;
try {
  region.startRegionOperation();
  acquiredLock = true;
  synchronized (scanner) {

代码示例来源：origin: apache/phoenix

QueryServicesOptions.DEFAULT_MUTATE_BATCH_SIZE_BYTES);
MutationList mutations = new MutationList(maxBatchSize);
region.startRegionOperation();
byte[] uuidValue = ServerCacheClient.generateId();
synchronized (innerScanner) {

代码示例来源：origin: apache/phoenix

byte[] row = append.getRow();
List<RowLock> locks = Lists.newArrayList();
region.startRegionOperation();
try {
  ServerUtil.acquireLock(region, row, locks);

代码示例来源：origin: apache/phoenix

final MemoryManager.MemoryChunk chunk = tenantCache.getMemoryManager().allocate(estSize);
final Region region = getRegion();
region.startRegionOperation();
try {

代码示例来源：origin: apache/phoenix

List<RowLock> locks = Lists.newArrayList();
TimeRange tr = increment.getTimeRange();
region.startRegionOperation();
try {
  ServerUtil.acquireLock(region, row, locks);

代码示例来源：origin: apache/phoenix

region.startRegionOperation();
acquiredLock = true;
synchronized (innerScanner) {

代码示例来源：origin: harbby/presto-connectors

@Override
 public Void call() throws Exception {
  LOG.debug("Starting region operation on " + region);
  region.startRegionOperation();
  try {
   LOG.debug("Flush region " + region.toString() + " started...");
   region.flush(true);
  } finally {
   LOG.debug("Closing region operation on " + region);
   region.closeRegionOperation();
  }
  return null;
 }
}

代码示例来源：origin: harbby/presto-connectors

region.startRegionOperation();
try {
 if (snapshotSkipFlush) {

代码示例来源：origin: org.apache.phoenix/phoenix-core

private long collectStatsInternal() throws IOException {
  long startTime = EnvironmentEdgeManager.currentTimeMillis();
  region.startRegionOperation();
  boolean hasMore = false;
  boolean noErrors = false;

代码示例来源：origin: com.aliyun.phoenix/ali-phoenix-core

private long collectStatsInternal() throws IOException {
  long startTime = EnvironmentEdgeManager.currentTimeMillis();
  region.startRegionOperation();
  boolean hasMore = false;
  boolean noErrors = false;

代码示例来源：origin: org.apache.phoenix/phoenix-core

final Tuple firstTuple;
final Region region = getRegion();
region.startRegionOperation();
try {
 Tuple tuple = iterator.next();

代码示例来源：origin: com.aliyun.phoenix/ali-phoenix-core

final MemoryManager.MemoryChunk chunk = tenantCache.getMemoryManager().allocate(estSize);
final Region region = getRegion();
region.startRegionOperation();
try {

代码示例来源：origin: harbby/presto-connectors

boolean forcible = request.getForcible();
long masterSystemTime = request.hasMasterSystemTime() ? request.getMasterSystemTime() : -1;
regionA.startRegionOperation(Operation.MERGE_REGION);
regionB.startRegionOperation(Operation.MERGE_REGION);
if (regionA.getRegionInfo().getReplicaId() != HRegionInfo.DEFAULT_REPLICA_ID ||
  regionB.getRegionInfo().getReplicaId() != HRegionInfo.DEFAULT_REPLICA_ID) {

代码示例来源：origin: harbby/presto-connectors

requestCount.increment();
Region region = getRegion(request.getRegion());
region.startRegionOperation(Operation.SPLIT_REGION);
if (region.getRegionInfo().getReplicaId() != HRegionInfo.DEFAULT_REPLICA_ID) {
 throw new IOException("Can't split replicas directly. "