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

Region.mutateRowsWithLocks介绍

[英]Perform atomic mutations within the region.
[中]在区域内进行原子突变。

代码示例

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

env.getRegion().mutateRowsWithLocks(mutations, rowsToLock, nonceGroup, nonce);
} catch (IOException e) {
 CoprocessorRpcUtils.setControllerException(controller, e);

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

private void mutateRowsWithLocks(final Region region, final List<Mutation> mutations, final Set<byte[]> rowsToLock,
    final long nonceGroup, final long nonce) throws IOException {
  // we need to mutate SYSTEM.CATALOG with HBase/login user if access is enabled.
  if (this.accessCheckEnabled) {
    User.runAsLoginUser(new PrivilegedExceptionAction<Void>() {
      @Override
      public Void run() throws Exception {
        final RpcCall rpcContext = RpcUtil.getRpcContext();
        // Setting RPC context as null so that user can be resetted
        try {
          RpcUtil.setRpcContext(null);
          region.mutateRowsWithLocks(mutations, rowsToLock, nonceGroup, nonce);
        } catch (Throwable e) {
          throw new IOException(e);
        } finally {
          // Setting RPC context back to original context of the RPC
          RpcUtil.setRpcContext(rpcContext);
        }
        return null;
      }
    });
  } else {
    region.mutateRowsWithLocks(mutations, rowsToLock, nonceGroup, nonce);
  }
}

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

@Override
  public Void run() throws Exception {
    final RpcCall rpcContext = RpcUtil.getRpcContext();
    // Setting RPC context as null so that user can be resetted
    try {
      RpcUtil.setRpcContext(null);
      region.mutateRowsWithLocks(mutations, rowsToLock, nonceGroup, nonce);
    } catch (Throwable e) {
      throw new IOException(e);
    } finally {
      // Setting RPC context back to original context of the RPC
      RpcUtil.setRpcContext(rpcContext);
    }
    return null;
  }
});

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

private void mutateRowsWithLocks(final Region region, final List<Mutation> mutations, final Set<byte[]> rowsToLock,
    final long nonceGroup, final long nonce) throws IOException {
  // we need to mutate SYSTEM.CATALOG with HBase/login user if access is enabled.
  if (this.accessCheckEnabled) {
    User.runAsLoginUser(new PrivilegedExceptionAction<Void>() {
      @Override
      public Void run() throws Exception {
        final RpcCall rpcContext = RpcUtil.getRpcContext();
        // Setting RPC context as null so that user can be resetted
        try {
          RpcUtil.setRpcContext(null);
          region.mutateRowsWithLocks(mutations, rowsToLock, nonceGroup, nonce);
        } catch (Throwable e) {
          throw new IOException(e);
        } finally {
          // Setting RPC context back to original context of the RPC
          RpcUtil.setRpcContext(rpcContext);
        }
        return null;
      }
    });
  } else {
    region.mutateRowsWithLocks(mutations, rowsToLock, nonceGroup, nonce);
  }
}

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

private void mutateRowsWithLocks(final Region region, final List<Mutation> mutations, final Set<byte[]> rowsToLock,
    final long nonceGroup, final long nonce) throws IOException {
  // we need to mutate SYSTEM.CATALOG with HBase/login user if access is enabled.
  if (this.accessCheckEnabled) {
    User.runAsLoginUser(new PrivilegedExceptionAction<Void>() {
      @Override
      public Void run() throws Exception {
        final RpcCall rpcContext = RpcUtil.getRpcContext();
        // Setting RPC context as null so that user can be resetted
        try {
          RpcUtil.setRpcContext(null);
          region.mutateRowsWithLocks(mutations, rowsToLock, nonceGroup, nonce);
        } catch (Throwable e) {
          throw new IOException(e);
        } finally {
          // Setting RPC context back to original context of the RPC
          RpcUtil.setRpcContext(rpcContext);
        }
        return null;
      }
    });
  } else {
    region.mutateRowsWithLocks(mutations, rowsToLock, nonceGroup, nonce);
  }
}

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

@Override
  public Void run() throws Exception {
    final RpcCall rpcContext = RpcUtil.getRpcContext();
    // Setting RPC context as null so that user can be resetted
    try {
      RpcUtil.setRpcContext(null);
      region.mutateRowsWithLocks(mutations, rowsToLock, nonceGroup, nonce);
    } catch (Throwable e) {
      throw new IOException(e);
    } finally {
      // Setting RPC context back to original context of the RPC
      RpcUtil.setRpcContext(rpcContext);
    }
    return null;
  }
});

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

@Override
  public Void run() throws Exception {
    final RpcCall rpcContext = RpcUtil.getRpcContext();
    // Setting RPC context as null so that user can be resetted
    try {
      RpcUtil.setRpcContext(null);
      region.mutateRowsWithLocks(mutations, rowsToLock, nonceGroup, nonce);
    } catch (Throwable e) {
      throw new IOException(e);
    } finally {
      // Setting RPC context back to original context of the RPC
      RpcUtil.setRpcContext(rpcContext);
    }
    return null;
  }
});

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

env.getRegion().mutateRowsWithLocks(mutations, rowsToLock, nonceGroup, nonce);
} catch (IOException e) {
 ResponseConverter.setControllerException(controller, e);