1. 包列表
  2. 类列表
  3. org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutateResponse

Java 类org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutateResponse 实例源码

项目：ditb    文件：HTable.java    
/**
 * {@inheritDoc}
 */
@Override
public boolean checkAndPut(final byte [] row,
    final byte [] family, final byte [] qualifier, final byte [] value,
    final Put put)
throws IOException {
  RegionServerCallable<Boolean> callable =
    new RegionServerCallable<Boolean>(connection, getName(), row) {
      @Override
      public Boolean call(int callTimeout) throws IOException {
        PayloadCarryingRpcController controller = rpcControllerFactory.newController();
        controller.setPriority(tableName);
        controller.setCallTimeout(callTimeout);
        try {
          MutateRequest request = RequestConverter.buildMutateRequest(
              getLocation().getRegionInfo().getRegionName(), row, family, qualifier,
              new BinaryComparator(value), CompareType.EQUAL, put);
          MutateResponse response = getStub().mutate(controller, request);
          return Boolean.valueOf(response.getProcessed());
        } catch (ServiceException se) {
          throw ProtobufUtil.getRemoteException(se);
        }
      }
    };
  return rpcCallerFactory.<Boolean> newCaller().callWithRetries(callable, this.operationTimeout);
}
项目：ditb    文件：HTable.java    
/**
 * {@inheritDoc}
 */
@Override
public boolean checkAndDelete(final byte [] row,
    final byte [] family, final byte [] qualifier, final byte [] value,
    final Delete delete)
throws IOException {
  RegionServerCallable<Boolean> callable =
    new RegionServerCallable<Boolean>(connection, getName(), row) {
      @Override
      public Boolean call(int callTimeout) throws IOException {
        PayloadCarryingRpcController controller = rpcControllerFactory.newController();
        controller.setPriority(tableName);
        controller.setCallTimeout(callTimeout);
        try {
          MutateRequest request = RequestConverter.buildMutateRequest(
            getLocation().getRegionInfo().getRegionName(), row, family, qualifier,
              new BinaryComparator(value), CompareType.EQUAL, delete);
          MutateResponse response = getStub().mutate(controller, request);
          return Boolean.valueOf(response.getProcessed());
        } catch (ServiceException se) {
          throw ProtobufUtil.getRemoteException(se);
        }
      }
    };
  return rpcCallerFactory.<Boolean> newCaller().callWithRetries(callable, this.operationTimeout);
}
项目：pbase    文件：HTable.java    
/**
 * {@inheritDoc}
 */
@Override
public boolean checkAndPut(final byte [] row,
    final byte [] family, final byte [] qualifier, final byte [] value,
    final Put put)
throws IOException {
  RegionServerCallable<Boolean> callable =
    new RegionServerCallable<Boolean>(connection, getName(), row) {
      @Override
      public Boolean call(int callTimeout) throws IOException {
        PayloadCarryingRpcController controller = rpcControllerFactory.newController();
        controller.setPriority(tableName);
        controller.setCallTimeout(callTimeout);
        try {
          MutateRequest request = RequestConverter.buildMutateRequest(
              getLocation().getRegionInfo().getRegionName(), row, family, qualifier,
              new BinaryComparator(value), CompareType.EQUAL, put);
          MutateResponse response = getStub().mutate(controller, request);
          return Boolean.valueOf(response.getProcessed());
        } catch (ServiceException se) {
          throw ProtobufUtil.getRemoteException(se);
        }
      }
    };
  return rpcCallerFactory.<Boolean> newCaller().callWithRetries(callable, this.operationTimeout);
}
项目：pbase    文件：HTable.java    
/**
 * {@inheritDoc}
 */
@Override
public boolean checkAndDelete(final byte [] row,
    final byte [] family, final byte [] qualifier, final byte [] value,
    final Delete delete)
throws IOException {
  RegionServerCallable<Boolean> callable =
    new RegionServerCallable<Boolean>(connection, getName(), row) {
      @Override
      public Boolean call(int callTimeout) throws IOException {
        PayloadCarryingRpcController controller = rpcControllerFactory.newController();
        controller.setPriority(tableName);
        controller.setCallTimeout(callTimeout);
        try {
          MutateRequest request = RequestConverter.buildMutateRequest(
            getLocation().getRegionInfo().getRegionName(), row, family, qualifier,
              new BinaryComparator(value), CompareType.EQUAL, delete);
          MutateResponse response = getStub().mutate(controller, request);
          return Boolean.valueOf(response.getProcessed());
        } catch (ServiceException se) {
          throw ProtobufUtil.getRemoteException(se);
        }
      }
    };
  return rpcCallerFactory.<Boolean> newCaller().callWithRetries(callable, this.operationTimeout);
}
项目：HIndex    文件：HTable.java    
/**
 * {@inheritDoc}
 */
@Override
public boolean checkAndPut(final byte [] row,
    final byte [] family, final byte [] qualifier, final byte [] value,
    final Put put)
throws IOException {
  RegionServerCallable<Boolean> callable =
    new RegionServerCallable<Boolean>(connection, getName(), row) {
      public Boolean call() throws IOException {
        try {
          MutateRequest request = RequestConverter.buildMutateRequest(
            getLocation().getRegionInfo().getRegionName(), row, family, qualifier,
              new BinaryComparator(value), CompareType.EQUAL, put);
          PayloadCarryingRpcController rpcController = rpcControllerFactory.newController();
          rpcController.setPriority(getTableName());
          MutateResponse response = getStub().mutate(rpcController, request);
          return Boolean.valueOf(response.getProcessed());
        } catch (ServiceException se) {
          throw ProtobufUtil.getRemoteException(se);
        }
      }
    };
  return rpcCallerFactory.<Boolean> newCaller().callWithRetries(callable, this.operationTimeout);
}
项目：HIndex    文件：HTable.java    
/**
 * {@inheritDoc}
 */
@Override
public boolean checkAndDelete(final byte [] row,
    final byte [] family, final byte [] qualifier, final byte [] value,
    final Delete delete)
throws IOException {
  RegionServerCallable<Boolean> callable =
    new RegionServerCallable<Boolean>(connection, getName(), row) {
      public Boolean call() throws IOException {
        try {
          MutateRequest request = RequestConverter.buildMutateRequest(
            getLocation().getRegionInfo().getRegionName(), row, family, qualifier,
              new BinaryComparator(value), CompareType.EQUAL, delete);
          PayloadCarryingRpcController rpcController = rpcControllerFactory.newController();
          rpcController.setPriority(getTableName());
          MutateResponse response = getStub().mutate(rpcController, request);
          return Boolean.valueOf(response.getProcessed());
        } catch (ServiceException se) {
          throw ProtobufUtil.getRemoteException(se);
        }
      }
    };
  return rpcCallerFactory.<Boolean> newCaller().callWithRetries(callable, this.operationTimeout);
}
项目：PyroDB    文件：HTable.java    
/**
 * {@inheritDoc}
 */
@Override
public boolean checkAndPut(final byte [] row,
    final byte [] family, final byte [] qualifier, final byte [] value,
    final Put put)
throws IOException {
  RegionServerCallable<Boolean> callable =
    new RegionServerCallable<Boolean>(connection, getName(), row) {
      public Boolean call(int callTimeout) throws IOException {
        PayloadCarryingRpcController controller = rpcControllerFactory.newController();
        controller.setPriority(tableName);
        controller.setCallTimeout(callTimeout);
        try {
          MutateRequest request = RequestConverter.buildMutateRequest(
            getLocation().getRegionInfo().getRegionName(), row, family, qualifier,
              new BinaryComparator(value), CompareType.EQUAL, put);
          MutateResponse response = getStub().mutate(controller, request);
          return Boolean.valueOf(response.getProcessed());
        } catch (ServiceException se) {
          throw ProtobufUtil.getRemoteException(se);
        }
      }
    };
  return rpcCallerFactory.<Boolean> newCaller().callWithRetries(callable, this.operationTimeout);
}
项目：PyroDB    文件：HTable.java    
/**
 * {@inheritDoc}
 */
@Override
public boolean checkAndPut(final byte [] row, final byte [] family,
    final byte [] qualifier, final CompareOp compareOp, final byte [] value,
    final Put put)
throws IOException {
  RegionServerCallable<Boolean> callable =
    new RegionServerCallable<Boolean>(connection, getName(), row) {
      public Boolean call(int callTimeout) throws IOException {
        PayloadCarryingRpcController controller = new PayloadCarryingRpcController();
        controller.setPriority(tableName);
        controller.setCallTimeout(callTimeout);
        try {
          CompareType compareType = CompareType.valueOf(compareOp.name());
          MutateRequest request = RequestConverter.buildMutateRequest(
            getLocation().getRegionInfo().getRegionName(), row, family, qualifier,
              new BinaryComparator(value), compareType, put);
          MutateResponse response = getStub().mutate(controller, request);
          return Boolean.valueOf(response.getProcessed());
        } catch (ServiceException se) {
          throw ProtobufUtil.getRemoteException(se);
        }
      }
    };
  return rpcCallerFactory.<Boolean> newCaller().callWithRetries(callable, this.operationTimeout);
}
项目：PyroDB    文件：HTable.java    
/**
 * {@inheritDoc}
 */
@Override
public boolean checkAndDelete(final byte [] row,
    final byte [] family, final byte [] qualifier, final byte [] value,
    final Delete delete)
throws IOException {
  RegionServerCallable<Boolean> callable =
    new RegionServerCallable<Boolean>(connection, getName(), row) {
      public Boolean call(int callTimeout) throws IOException {
        PayloadCarryingRpcController controller = rpcControllerFactory.newController();
        controller.setPriority(tableName);
        controller.setCallTimeout(callTimeout);
        try {
          MutateRequest request = RequestConverter.buildMutateRequest(
            getLocation().getRegionInfo().getRegionName(), row, family, qualifier,
              new BinaryComparator(value), CompareType.EQUAL, delete);
          MutateResponse response = getStub().mutate(controller, request);
          return Boolean.valueOf(response.getProcessed());
        } catch (ServiceException se) {
          throw ProtobufUtil.getRemoteException(se);
        }
      }
    };
  return rpcCallerFactory.<Boolean> newCaller().callWithRetries(callable, this.operationTimeout);
}
项目：PyroDB    文件：HTable.java    
/**
 * {@inheritDoc}
 */
@Override
public boolean checkAndDelete(final byte [] row, final byte [] family,
    final byte [] qualifier, final CompareOp compareOp, final byte [] value,
    final Delete delete)
throws IOException {
  RegionServerCallable<Boolean> callable =
    new RegionServerCallable<Boolean>(connection, getName(), row) {
      public Boolean call(int callTimeout) throws IOException {
        PayloadCarryingRpcController controller = rpcControllerFactory.newController();
        controller.setPriority(tableName);
        controller.setCallTimeout(callTimeout);
        try {
          CompareType compareType = CompareType.valueOf(compareOp.name());
          MutateRequest request = RequestConverter.buildMutateRequest(
            getLocation().getRegionInfo().getRegionName(), row, family, qualifier,
              new BinaryComparator(value), compareType, delete);
          MutateResponse response = getStub().mutate(controller, request);
          return Boolean.valueOf(response.getProcessed());
        } catch (ServiceException se) {
          throw ProtobufUtil.getRemoteException(se);
        }
      }
    };
  return rpcCallerFactory.<Boolean> newCaller().callWithRetries(callable, this.operationTimeout);
}
项目：c5    文件：HTable.java    
/**
 * {@inheritDoc}
 */
@Override
public boolean checkAndPut(final byte [] row,
    final byte [] family, final byte [] qualifier, final byte [] value,
    final Put put)
throws IOException {
  RegionServerCallable<Boolean> callable =
    new RegionServerCallable<Boolean>(connection, getName(), row) {
      public Boolean call() throws IOException {
        try {
          MutateRequest request = RequestConverter.buildMutateRequest(
            getLocation().getRegionInfo().getRegionName(), row, family, qualifier,
              new BinaryComparator(value), CompareType.EQUAL, put);
          MutateResponse response = getStub().mutate(null, request);
          return Boolean.valueOf(response.getProcessed());
        } catch (ServiceException se) {
          throw ProtobufUtil.getRemoteException(se);
        }
      }
    };
  return rpcCallerFactory.<Boolean> newCaller().callWithRetries(callable, this.operationTimeout);
}
项目：c5    文件：HTable.java    
/**
 * {@inheritDoc}
 */
@Override
public boolean checkAndDelete(final byte [] row,
    final byte [] family, final byte [] qualifier, final byte [] value,
    final Delete delete)
throws IOException {
  RegionServerCallable<Boolean> callable =
    new RegionServerCallable<Boolean>(connection, getName(), row) {
      public Boolean call() throws IOException {
        try {
          MutateRequest request = RequestConverter.buildMutateRequest(
            getLocation().getRegionInfo().getRegionName(), row, family, qualifier,
              new BinaryComparator(value), CompareType.EQUAL, delete);
          MutateResponse response = getStub().mutate(null, request);
          return Boolean.valueOf(response.getProcessed());
        } catch (ServiceException se) {
          throw ProtobufUtil.getRemoteException(se);
        }
      }
    };
  return rpcCallerFactory.<Boolean> newCaller().callWithRetries(callable, this.operationTimeout);
}
项目：DominoHBase    文件：HTable.java    
/**
 * {@inheritDoc}
 */
@Override
public boolean checkAndPut(final byte [] row,
    final byte [] family, final byte [] qualifier, final byte [] value,
    final Put put)
throws IOException {
  return new ServerCallable<Boolean>(connection, tableName, row, operationTimeout) {
        public Boolean call() throws IOException {
          try {
            MutateRequest request = RequestConverter.buildMutateRequest(
              location.getRegionInfo().getRegionName(), row, family, qualifier,
              new BinaryComparator(value), CompareType.EQUAL, put);
            MutateResponse response = server.mutate(null, request);
            return Boolean.valueOf(response.getProcessed());
          } catch (ServiceException se) {
            throw ProtobufUtil.getRemoteException(se);
          }
        }
      }.withRetries();
}
项目：DominoHBase    文件：HTable.java    
/**
 * {@inheritDoc}
 */
@Override
public boolean checkAndDelete(final byte [] row,
    final byte [] family, final byte [] qualifier, final byte [] value,
    final Delete delete)
throws IOException {
  return new ServerCallable<Boolean>(connection, tableName, row, operationTimeout) {
        public Boolean call() throws IOException {
          try {
            MutateRequest request = RequestConverter.buildMutateRequest(
              location.getRegionInfo().getRegionName(), row, family, qualifier,
              new BinaryComparator(value), CompareType.EQUAL, delete);
            MutateResponse response = server.mutate(null, request);
            return Boolean.valueOf(response.getProcessed());
          } catch (ServiceException se) {
            throw ProtobufUtil.getRemoteException(se);
          }
        }
      }.withRetries();
}
项目：ditb    文件：RSRpcServices.java    
private void addResult(final MutateResponse.Builder builder,
    final Result result, final PayloadCarryingRpcController rpcc) {
  if (result == null) return;
  if (isClientCellBlockSupport()) {
    builder.setResult(ProtobufUtil.toResultNoData(result));
    rpcc.setCellScanner(result.cellScanner());
  } else {
    ClientProtos.Result pbr = ProtobufUtil.toResult(result);
    builder.setResult(pbr);
  }
}
项目：ditb    文件：HTable.java    
/**
 * {@inheritDoc}
 */
@Override
public boolean checkAndPut(final byte [] row, final byte [] family,
    final byte [] qualifier, final CompareOp compareOp, final byte [] value,
    final Put put)
throws IOException {
  RegionServerCallable<Boolean> callable =
    new RegionServerCallable<Boolean>(connection, getName(), row) {
      @Override
      public Boolean call(int callTimeout) throws IOException {
        PayloadCarryingRpcController controller = new PayloadCarryingRpcController();
        controller.setPriority(tableName);
        controller.setCallTimeout(callTimeout);
        try {
          CompareType compareType = CompareType.valueOf(compareOp.name());
          MutateRequest request = RequestConverter.buildMutateRequest(
            getLocation().getRegionInfo().getRegionName(), row, family, qualifier,
              new BinaryComparator(value), compareType, put);
          MutateResponse response = getStub().mutate(controller, request);
          return Boolean.valueOf(response.getProcessed());
        } catch (ServiceException se) {
          throw ProtobufUtil.getRemoteException(se);
        }
      }
    };
  return rpcCallerFactory.<Boolean> newCaller().callWithRetries(callable, this.operationTimeout);
}
项目：ditb    文件：HTable.java    
/**
 * {@inheritDoc}
 */
@Override
public boolean checkAndDelete(final byte [] row, final byte [] family,
    final byte [] qualifier, final CompareOp compareOp, final byte [] value,
    final Delete delete)
throws IOException {
  RegionServerCallable<Boolean> callable =
    new RegionServerCallable<Boolean>(connection, getName(), row) {
      @Override
      public Boolean call(int callTimeout) throws IOException {
        PayloadCarryingRpcController controller = rpcControllerFactory.newController();
        controller.setPriority(tableName);
        controller.setCallTimeout(callTimeout);
        try {
          CompareType compareType = CompareType.valueOf(compareOp.name());
          MutateRequest request = RequestConverter.buildMutateRequest(
            getLocation().getRegionInfo().getRegionName(), row, family, qualifier,
              new BinaryComparator(value), compareType, delete);
          MutateResponse response = getStub().mutate(controller, request);
          return Boolean.valueOf(response.getProcessed());
        } catch (ServiceException se) {
          throw ProtobufUtil.getRemoteException(se);
        }
      }
    };
  return rpcCallerFactory.<Boolean> newCaller().callWithRetries(callable, this.operationTimeout);
}
项目：pbase    文件：RSRpcServices.java    
private void addResult(final MutateResponse.Builder builder,
                       final Result result, final PayloadCarryingRpcController rpcc) {
    if (result == null) return;
    if (isClientCellBlockSupport()) {
        builder.setResult(ProtobufUtil.toResultNoData(result));
        rpcc.setCellScanner(result.cellScanner());
    } else {
        ClientProtos.Result pbr = ProtobufUtil.toResult(result);
        builder.setResult(pbr);
    }
}
项目：pbase    文件：HTable.java    
/**
 * {@inheritDoc}
 */
@Override
public boolean checkAndPut(final byte [] row, final byte [] family,
    final byte [] qualifier, final CompareOp compareOp, final byte [] value,
    final Put put)
throws IOException {
  RegionServerCallable<Boolean> callable =
    new RegionServerCallable<Boolean>(connection, getName(), row) {
      @Override
      public Boolean call(int callTimeout) throws IOException {
        PayloadCarryingRpcController controller = new PayloadCarryingRpcController();
        controller.setPriority(tableName);
        controller.setCallTimeout(callTimeout);
        try {
          CompareType compareType = CompareType.valueOf(compareOp.name());
          MutateRequest request = RequestConverter.buildMutateRequest(
            getLocation().getRegionInfo().getRegionName(), row, family, qualifier,
              new BinaryComparator(value), compareType, put);
          MutateResponse response = getStub().mutate(controller, request);
          return Boolean.valueOf(response.getProcessed());
        } catch (ServiceException se) {
          throw ProtobufUtil.getRemoteException(se);
        }
      }
    };
  return rpcCallerFactory.<Boolean> newCaller().callWithRetries(callable, this.operationTimeout);
}
项目：pbase    文件：HTable.java    
/**
 * {@inheritDoc}
 */
@Override
public boolean checkAndDelete(final byte [] row, final byte [] family,
    final byte [] qualifier, final CompareOp compareOp, final byte [] value,
    final Delete delete)
throws IOException {
  RegionServerCallable<Boolean> callable =
    new RegionServerCallable<Boolean>(connection, getName(), row) {
      @Override
      public Boolean call(int callTimeout) throws IOException {
        PayloadCarryingRpcController controller = rpcControllerFactory.newController();
        controller.setPriority(tableName);
        controller.setCallTimeout(callTimeout);
        try {
          CompareType compareType = CompareType.valueOf(compareOp.name());
          MutateRequest request = RequestConverter.buildMutateRequest(
            getLocation().getRegionInfo().getRegionName(), row, family, qualifier,
              new BinaryComparator(value), compareType, delete);
          MutateResponse response = getStub().mutate(controller, request);
          return Boolean.valueOf(response.getProcessed());
        } catch (ServiceException se) {
          throw ProtobufUtil.getRemoteException(se);
        }
      }
    };
  return rpcCallerFactory.<Boolean> newCaller().callWithRetries(callable, this.operationTimeout);
}
项目：HIndex    文件：HRegionServer.java    
private void addResult(final MutateResponse.Builder builder,
    final Result result, final PayloadCarryingRpcController rpcc) {
  if (result == null) return;
  if (isClientCellBlockSupport()) {
    builder.setResult(ProtobufUtil.toResultNoData(result));
    rpcc.setCellScanner(result.cellScanner());
  } else {
    ClientProtos.Result pbr = ProtobufUtil.toResult(result);
    builder.setResult(pbr);
  }
}
项目：HIndex    文件：TestCatalogJanitor.java    
MockServer(final HBaseTestingUtility htu)
throws NotAllMetaRegionsOnlineException, IOException, InterruptedException {
  this.c = htu.getConfiguration();
  ClientProtos.ClientService.BlockingInterface ri =
    Mockito.mock(ClientProtos.ClientService.BlockingInterface.class);
  MutateResponse.Builder builder = MutateResponse.newBuilder();
  builder.setProcessed(true);
  try {
    Mockito.when(ri.mutate(
      (RpcController)Mockito.any(), (MutateRequest)Mockito.any())).
        thenReturn(builder.build());
  } catch (ServiceException se) {
    throw ProtobufUtil.getRemoteException(se);
  }
  // Mock an HConnection and a AdminProtocol implementation.  Have the
  // HConnection return the HRI.  Have the HRI return a few mocked up responses
  // to make our test work.
  this.connection =
    HConnectionTestingUtility.getMockedConnectionAndDecorate(this.c,
      Mockito.mock(AdminProtos.AdminService.BlockingInterface.class), ri,
        ServerName.valueOf("example.org,12345,6789"),
      HRegionInfo.FIRST_META_REGIONINFO);
  // Set hbase.rootdir into test dir.
  FileSystem fs = FileSystem.get(this.c);
  Path rootdir = FSUtils.getRootDir(this.c);
  FSUtils.setRootDir(this.c, rootdir);
  this.ct = Mockito.mock(CatalogTracker.class);
  AdminProtos.AdminService.BlockingInterface hri =
    Mockito.mock(AdminProtos.AdminService.BlockingInterface.class);
  Mockito.when(this.ct.getConnection()).thenReturn(this.connection);
  Mockito.when(ct.waitForMetaServerConnection(Mockito.anyLong())).thenReturn(hri);
}
项目：HIndex    文件：HTable.java    
/**
 * {@inheritDoc}
 */
@Override
public long incrementColumnValue(final byte [] row, final byte [] family,
    final byte [] qualifier, final long amount, final Durability durability)
throws IOException {
  NullPointerException npe = null;
  if (row == null) {
    npe = new NullPointerException("row is null");
  } else if (family == null) {
    npe = new NullPointerException("family is null");
  } else if (qualifier == null) {
    npe = new NullPointerException("qualifier is null");
  }
  if (npe != null) {
    throw new IOException(
        "Invalid arguments to incrementColumnValue", npe);
  }

  NonceGenerator ng = this.connection.getNonceGenerator();
  final long nonceGroup = ng.getNonceGroup(), nonce = ng.newNonce();
  RegionServerCallable<Long> callable =
    new RegionServerCallable<Long>(connection, getName(), row) {
      public Long call() throws IOException {
        try {
          MutateRequest request = RequestConverter.buildIncrementRequest(
            getLocation().getRegionInfo().getRegionName(), row, family,
            qualifier, amount, durability, nonceGroup, nonce);
          PayloadCarryingRpcController rpcController = rpcControllerFactory.newController();
          rpcController.setPriority(getTableName());
          MutateResponse response = getStub().mutate(rpcController, request);
          Result result =
            ProtobufUtil.toResult(response.getResult(), rpcController.cellScanner());
          return Long.valueOf(Bytes.toLong(result.getValue(family, qualifier)));
        } catch (ServiceException se) {
          throw ProtobufUtil.getRemoteException(se);
        }
      }
    };
  return rpcCallerFactory.<Long> newCaller().callWithRetries(callable, this.operationTimeout);
}
项目：PyroDB    文件：RSRpcServices.java    
private void addResult(final MutateResponse.Builder builder,
    final Result result, final PayloadCarryingRpcController rpcc) {
  if (result == null) return;
  if (isClientCellBlockSupport()) {
    builder.setResult(ProtobufUtil.toResultNoData(result));
    rpcc.setCellScanner(result.cellScanner());
  } else {
    ClientProtos.Result pbr = ProtobufUtil.toResult(result);
    builder.setResult(pbr);
  }
}
项目：c5    文件：HRegionServer.java    
private void addResult(final MutateResponse.Builder builder,
    final Result result, final PayloadCarryingRpcController rpcc) {
  if (result == null) return;
  if (isClientCellBlockSupport()) {
    builder.setResult(ProtobufUtil.toResultNoData(result));
    rpcc.setCellScanner(result.cellScanner());
  } else {
    ClientProtos.Result pbr = ProtobufUtil.toResult(result);
    builder.setResult(pbr);
  }
}
项目：c5    文件：TestCatalogJanitor.java    
MockServer(final HBaseTestingUtility htu)
throws NotAllMetaRegionsOnlineException, IOException, InterruptedException {
  this.c = htu.getConfiguration();
  ClientProtos.ClientService.BlockingInterface ri =
    Mockito.mock(ClientProtos.ClientService.BlockingInterface.class);
  MutateResponse.Builder builder = MutateResponse.newBuilder();
  builder.setProcessed(true);
  try {
    Mockito.when(ri.mutate(
      (RpcController)Mockito.any(), (MutateRequest)Mockito.any())).
        thenReturn(builder.build());
  } catch (ServiceException se) {
    throw ProtobufUtil.getRemoteException(se);
  }
  // Mock an HConnection and a AdminProtocol implementation.  Have the
  // HConnection return the HRI.  Have the HRI return a few mocked up responses
  // to make our test work.
  this.connection =
    HConnectionTestingUtility.getMockedConnectionAndDecorate(this.c,
      Mockito.mock(AdminProtos.AdminService.BlockingInterface.class), ri,
        ServerName.valueOf("example.org,12345,6789"),
      HRegionInfo.FIRST_META_REGIONINFO);
  // Set hbase.rootdir into test dir.
  FileSystem fs = FileSystem.get(this.c);
  Path rootdir = FSUtils.getRootDir(this.c);
  FSUtils.setRootDir(this.c, rootdir);
  this.ct = Mockito.mock(CatalogTracker.class);
  AdminProtos.AdminService.BlockingInterface hri =
    Mockito.mock(AdminProtos.AdminService.BlockingInterface.class);
  Mockito.when(this.ct.getConnection()).thenReturn(this.connection);
  Mockito.when(ct.waitForMetaServerConnection(Mockito.anyLong())).thenReturn(hri);
}
项目：c5    文件：HTable.java    
/**
 * {@inheritDoc}
 */
@Override
public long incrementColumnValue(final byte [] row, final byte [] family,
    final byte [] qualifier, final long amount, final Durability durability)
throws IOException {
  NullPointerException npe = null;
  if (row == null) {
    npe = new NullPointerException("row is null");
  } else if (family == null) {
    npe = new NullPointerException("family is null");
  } else if (qualifier == null) {
    npe = new NullPointerException("qualifier is null");
  }
  if (npe != null) {
    throw new IOException(
        "Invalid arguments to incrementColumnValue", npe);
  }

  RegionServerCallable<Long> callable =
    new RegionServerCallable<Long>(connection, getName(), row) {
      public Long call() throws IOException {
        try {
          MutateRequest request = RequestConverter.buildMutateRequest(
            getLocation().getRegionInfo().getRegionName(), row, family,
            qualifier, amount, durability);
          PayloadCarryingRpcController rpcController = new PayloadCarryingRpcController();
          rpcController.setPriority(getTableName());
          MutateResponse response = getStub().mutate(rpcController, request);
          Result result =
            ProtobufUtil.toResult(response.getResult(), rpcController.cellScanner());
          return Long.valueOf(Bytes.toLong(result.getValue(family, qualifier)));
        } catch (ServiceException se) {
          throw ProtobufUtil.getRemoteException(se);
        }
      }
    };
  return rpcCallerFactory.<Long> newCaller().callWithRetries(callable, this.operationTimeout);
}
项目：DominoHBase    文件：HTable.java    
/**
 * {@inheritDoc}
 */
@Override
public long incrementColumnValue(final byte [] row, final byte [] family,
    final byte [] qualifier, final long amount, final boolean writeToWAL)
throws IOException {
  NullPointerException npe = null;
  if (row == null) {
    npe = new NullPointerException("row is null");
  } else if (family == null) {
    npe = new NullPointerException("family is null");
  } else if (qualifier == null) {
    npe = new NullPointerException("qualifier is null");
  }
  if (npe != null) {
    throw new IOException(
        "Invalid arguments to incrementColumnValue", npe);
  }
  return new ServerCallable<Long>(connection, tableName, row, operationTimeout) {
        public Long call() throws IOException {
          try {
            MutateRequest request = RequestConverter.buildMutateRequest(
              location.getRegionInfo().getRegionName(), row, family,
              qualifier, amount, writeToWAL);
            MutateResponse response = server.mutate(null, request);
            Result result = ProtobufUtil.toResult(response.getResult());
            return Long.valueOf(Bytes.toLong(result.getValue(family, qualifier)));
          } catch (ServiceException se) {
            throw ProtobufUtil.getRemoteException(se);
          }
        }
      }.withRetries();
}
项目：DominoHBase    文件：TestCatalogJanitor.java    
MockServer(final HBaseTestingUtility htu)
throws NotAllMetaRegionsOnlineException, IOException, InterruptedException {
  this.c = htu.getConfiguration();
  ClientProtocol ri = Mockito.mock(ClientProtocol.class);
  MutateResponse.Builder builder = MutateResponse.newBuilder();
  builder.setProcessed(true);
  try {
    Mockito.when(ri.mutate(
      (RpcController)Mockito.any(), (MutateRequest)Mockito.any())).
        thenReturn(builder.build());
  } catch (ServiceException se) {
    throw ProtobufUtil.getRemoteException(se);
  }
  // Mock an HConnection and a AdminProtocol implementation.  Have the
  // HConnection return the HRI.  Have the HRI return a few mocked up responses
  // to make our test work.
  this.connection =
    HConnectionTestingUtility.getMockedConnectionAndDecorate(this.c,
      Mockito.mock(AdminProtocol.class), ri,
      new ServerName("example.org,12345,6789"),
      HRegionInfo.FIRST_META_REGIONINFO);
  // Set hbase.rootdir into test dir.
  FileSystem fs = FileSystem.get(this.c);
  Path rootdir = fs.makeQualified(new Path(this.c.get(HConstants.HBASE_DIR)));
  this.c.set(HConstants.HBASE_DIR, rootdir.toString());
  this.ct = Mockito.mock(CatalogTracker.class);
  AdminProtocol hri = Mockito.mock(AdminProtocol.class);
  Mockito.when(this.ct.getConnection()).thenReturn(this.connection);
  Mockito.when(ct.waitForMetaServerConnectionDefault()).thenReturn(hri);
}
项目：ditb    文件：MockRegionServer.java    
@Override
public MutateResponse mutate(RpcController controller, MutateRequest request)
    throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}
项目：ditb    文件：HTable.java    
/**
 * {@inheritDoc}
 */
@Override
public long incrementColumnValue(final byte [] row, final byte [] family,
    final byte [] qualifier, final long amount, final Durability durability)
throws IOException {
  NullPointerException npe = null;
  if (row == null) {
    npe = new NullPointerException("row is null");
  } else if (family == null) {
    npe = new NullPointerException("family is null");
  } else if (qualifier == null) {
    npe = new NullPointerException("qualifier is null");
  }
  if (npe != null) {
    throw new IOException(
        "Invalid arguments to incrementColumnValue", npe);
  }

  NonceGenerator ng = this.connection.getNonceGenerator();
  final long nonceGroup = ng.getNonceGroup(), nonce = ng.newNonce();
  RegionServerCallable<Long> callable =
    new RegionServerCallable<Long>(connection, getName(), row) {
      @Override
      public Long call(int callTimeout) throws IOException {
        PayloadCarryingRpcController controller = rpcControllerFactory.newController();
        controller.setPriority(getTableName());
        controller.setCallTimeout(callTimeout);
        try {
          MutateRequest request = RequestConverter.buildIncrementRequest(
            getLocation().getRegionInfo().getRegionName(), row, family,
            qualifier, amount, durability, nonceGroup, nonce);
          MutateResponse response = getStub().mutate(controller, request);
          Result result =
            ProtobufUtil.toResult(response.getResult(), controller.cellScanner());
          return Long.valueOf(Bytes.toLong(result.getValue(family, qualifier)));
        } catch (ServiceException se) {
          throw ProtobufUtil.getRemoteException(se);
        }
      }
    };
  return rpcCallerFactory.<Long> newCaller().callWithRetries(callable, this.operationTimeout);
}
项目：ditb    文件：TestClientNoCluster.java    
@Override
public MutateResponse mutate(RpcController controller,
    MutateRequest request) throws ServiceException {
  throw new NotImplementedException();
}
项目：pbase    文件：MockRegionServer.java    
@Override
public MutateResponse mutate(RpcController controller, MutateRequest request)
    throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}
项目：pbase    文件：HTable.java    
/**
 * {@inheritDoc}
 */
@Override
public long incrementColumnValue(final byte [] row, final byte [] family,
    final byte [] qualifier, final long amount, final Durability durability)
throws IOException {
  NullPointerException npe = null;
  if (row == null) {
    npe = new NullPointerException("row is null");
  } else if (family == null) {
    npe = new NullPointerException("family is null");
  } else if (qualifier == null) {
    npe = new NullPointerException("qualifier is null");
  }
  if (npe != null) {
    throw new IOException(
        "Invalid arguments to incrementColumnValue", npe);
  }

  NonceGenerator ng = this.connection.getNonceGenerator();
  final long nonceGroup = ng.getNonceGroup(), nonce = ng.newNonce();
  RegionServerCallable<Long> callable =
    new RegionServerCallable<Long>(connection, getName(), row) {
      @Override
      public Long call(int callTimeout) throws IOException {
        PayloadCarryingRpcController controller = rpcControllerFactory.newController();
        controller.setPriority(getTableName());
        controller.setCallTimeout(callTimeout);
        try {
          MutateRequest request = RequestConverter.buildIncrementRequest(
            getLocation().getRegionInfo().getRegionName(), row, family,
            qualifier, amount, durability, nonceGroup, nonce);
          MutateResponse response = getStub().mutate(controller, request);
          Result result =
            ProtobufUtil.toResult(response.getResult(), controller.cellScanner());
          return Long.valueOf(Bytes.toLong(result.getValue(family, qualifier)));
        } catch (ServiceException se) {
          throw ProtobufUtil.getRemoteException(se);
        }
      }
    };
  return rpcCallerFactory.<Long> newCaller().callWithRetries(callable, this.operationTimeout);
}
项目：pbase    文件：TestClientNoCluster.java    
@Override
public MutateResponse mutate(RpcController controller,
    MutateRequest request) throws ServiceException {
  throw new NotImplementedException();
}
项目：HIndex    文件：MockRegionServer.java    
@Override
public MutateResponse mutate(RpcController controller, MutateRequest request)
    throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}
项目：HIndex    文件：TestClientNoCluster.java    
@Override
public MutateResponse mutate(RpcController controller,
    MutateRequest request) throws ServiceException {
  throw new NotImplementedException();
}
项目：PyroDB    文件：MockRegionServer.java    
@Override
public MutateResponse mutate(RpcController controller, MutateRequest request)
    throws ServiceException {
  // TODO Auto-generated method stub
  return null;
}
项目：PyroDB    文件：HTable.java    
/**
 * {@inheritDoc}
 */
@Override
public long incrementColumnValue(final byte [] row, final byte [] family,
    final byte [] qualifier, final long amount, final Durability durability)
throws IOException {
  NullPointerException npe = null;
  if (row == null) {
    npe = new NullPointerException("row is null");
  } else if (family == null) {
    npe = new NullPointerException("family is null");
  } else if (qualifier == null) {
    npe = new NullPointerException("qualifier is null");
  }
  if (npe != null) {
    throw new IOException(
        "Invalid arguments to incrementColumnValue", npe);
  }

  NonceGenerator ng = this.connection.getNonceGenerator();
  final long nonceGroup = ng.getNonceGroup(), nonce = ng.newNonce();
  RegionServerCallable<Long> callable =
    new RegionServerCallable<Long>(connection, getName(), row) {
      public Long call(int callTimeout) throws IOException {
        PayloadCarryingRpcController controller = rpcControllerFactory.newController();
        controller.setPriority(getTableName());
        controller.setCallTimeout(callTimeout);
        try {
          MutateRequest request = RequestConverter.buildIncrementRequest(
            getLocation().getRegionInfo().getRegionName(), row, family,
            qualifier, amount, durability, nonceGroup, nonce);
          MutateResponse response = getStub().mutate(controller, request);
          Result result =
            ProtobufUtil.toResult(response.getResult(), controller.cellScanner());
          return Long.valueOf(Bytes.toLong(result.getValue(family, qualifier)));
        } catch (ServiceException se) {
          throw ProtobufUtil.getRemoteException(se);
        }
      }
    };
  return rpcCallerFactory.<Long> newCaller().callWithRetries(callable, this.operationTimeout);
}
项目：PyroDB    文件：TestClientNoCluster.java    
@Override
public MutateResponse mutate(RpcController controller,
    MutateRequest request) throws ServiceException {
  throw new NotImplementedException();
}