Apache/hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-26002 MultiRowMutationEndpoint should return the result of the conditional update (addendum)

Browse Source 
Signed-off-by: Duo Zhang <zhangduo@apache.org>
This commit is contained in:
Toshihiro Suzuki 2021-06-15 09:42:49 +09:00
parent 97f90e0be2
commit 4262887432
2 changed files with 9 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hbase-server/src/main/java/org/apache/hadoop/hbase/coprocessor/MultiRowMutationEndpoint.java
View File

@ -96,7 +96,7 @@ import org.apache.hadoop.hbase.shaded.protobuf.generated.MultiRowMutationProtos.
* MultiRowMutationService.BlockingInterface service = * MultiRowMutationService.BlockingInterface service =
* MultiRowMutationService.newBlockingStub(channel); * MultiRowMutationService.newBlockingStub(channel);
* MutateRowsRequest mrm = mrmBuilder.build(); * MutateRowsRequest mrm = mrmBuilder.build();
* MultiRowMutationProtos.MutateRowsResponse response = service.mutateRows(null, mrm); * MutateRowsResponse response = service.mutateRows(null, mrm);
* *
* // We can get the result of the conditional update * // We can get the result of the conditional update
* boolean processed = response.getProcessed(); * boolean processed = response.getProcessed();

23
hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestFromClientSide5.java
View File

@ -76,7 +76,6 @@ import org.apache.hadoop.hbase.regionserver.HRegion;
import org.apache.hadoop.hbase.regionserver.HRegionServer; import org.apache.hadoop.hbase.regionserver.HRegionServer;
import org.apache.hadoop.hbase.regionserver.HStore; import org.apache.hadoop.hbase.regionserver.HStore;
import org.apache.hadoop.hbase.regionserver.NoSuchColumnFamilyException; import org.apache.hadoop.hbase.regionserver.NoSuchColumnFamilyException;
import org.apache.hadoop.hbase.shaded.protobuf.generated.MultiRowMutationProtos;
import org.apache.hadoop.hbase.testclassification.ClientTests; import org.apache.hadoop.hbase.testclassification.ClientTests;
import org.apache.hadoop.hbase.testclassification.LargeTests; import org.apache.hadoop.hbase.testclassification.LargeTests;
import org.apache.hadoop.hbase.util.Bytes; import org.apache.hadoop.hbase.util.Bytes;
@ -99,6 +98,7 @@ import org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutationPr
import org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutationProto.MutationType; import org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutationProto.MutationType;
import org.apache.hadoop.hbase.shaded.protobuf.generated.MultiRowMutationProtos.MultiRowMutationService; import org.apache.hadoop.hbase.shaded.protobuf.generated.MultiRowMutationProtos.MultiRowMutationService;
import org.apache.hadoop.hbase.shaded.protobuf.generated.MultiRowMutationProtos.MutateRowsRequest; import org.apache.hadoop.hbase.shaded.protobuf.generated.MultiRowMutationProtos.MutateRowsRequest;
import org.apache.hadoop.hbase.shaded.protobuf.generated.MultiRowMutationProtos.MutateRowsResponse;
/** /**
* Run tests that use the HBase clients; {@link Table}. * Run tests that use the HBase clients; {@link Table}.
@ -302,8 +302,7 @@ public class TestFromClientSide5 extends FromClientSideBase {
CoprocessorRpcChannel channel = t.coprocessorService(ROW); CoprocessorRpcChannel channel = t.coprocessorService(ROW);
MultiRowMutationService.BlockingInterface service = MultiRowMutationService.BlockingInterface service =
MultiRowMutationService.newBlockingStub(channel); MultiRowMutationService.newBlockingStub(channel);
MultiRowMutationProtos.MutateRowsResponse response = MutateRowsResponse response = service.mutateRows(null, mrmBuilder.build());
service.mutateRows(null, mrmBuilder.build());
// Assert // Assert
assertTrue(response.getProcessed()); assertTrue(response.getProcessed());
@ -353,8 +352,7 @@ public class TestFromClientSide5 extends FromClientSideBase {
CoprocessorRpcChannel channel = t.coprocessorService(ROW); CoprocessorRpcChannel channel = t.coprocessorService(ROW);
MultiRowMutationService.BlockingInterface service = MultiRowMutationService.BlockingInterface service =
MultiRowMutationService.newBlockingStub(channel); MultiRowMutationService.newBlockingStub(channel);
MultiRowMutationProtos.MutateRowsResponse response = MutateRowsResponse response = service.mutateRows(null, mrmBuilder.build());
service.mutateRows(null, mrmBuilder.build());
// Assert // Assert
assertTrue(response.getProcessed()); assertTrue(response.getProcessed());
@ -400,8 +398,7 @@ public class TestFromClientSide5 extends FromClientSideBase {
CoprocessorRpcChannel channel = t.coprocessorService(ROW); CoprocessorRpcChannel channel = t.coprocessorService(ROW);
MultiRowMutationService.BlockingInterface service = MultiRowMutationService.BlockingInterface service =
MultiRowMutationService.newBlockingStub(channel); MultiRowMutationService.newBlockingStub(channel);
MultiRowMutationProtos.MutateRowsResponse response = MutateRowsResponse response = service.mutateRows(null, mrmBuilder.build());
service.mutateRows(null, mrmBuilder.build());
// Assert // Assert
assertFalse(response.getProcessed()); assertFalse(response.getProcessed());
@ -449,8 +446,7 @@ public class TestFromClientSide5 extends FromClientSideBase {
CoprocessorRpcChannel channel = t.coprocessorService(ROW); CoprocessorRpcChannel channel = t.coprocessorService(ROW);
MultiRowMutationService.BlockingInterface service = MultiRowMutationService.BlockingInterface service =
MultiRowMutationService.newBlockingStub(channel); MultiRowMutationService.newBlockingStub(channel);
MultiRowMutationProtos.MutateRowsResponse response = MutateRowsResponse response = service.mutateRows(null, mrmBuilder.build());
service.mutateRows(null, mrmBuilder.build());
// Assert // Assert
assertTrue(response.getProcessed()); assertTrue(response.getProcessed());
@ -498,8 +494,7 @@ public class TestFromClientSide5 extends FromClientSideBase {
CoprocessorRpcChannel channel = t.coprocessorService(ROW); CoprocessorRpcChannel channel = t.coprocessorService(ROW);
MultiRowMutationService.BlockingInterface service = MultiRowMutationService.BlockingInterface service =
MultiRowMutationService.newBlockingStub(channel); MultiRowMutationService.newBlockingStub(channel);
MultiRowMutationProtos.MutateRowsResponse response = MutateRowsResponse response = service.mutateRows(null, mrmBuilder.build());
service.mutateRows(null, mrmBuilder.build());
// Assert // Assert
assertFalse(response.getProcessed()); assertFalse(response.getProcessed());
@ -549,8 +544,7 @@ public class TestFromClientSide5 extends FromClientSideBase {
CoprocessorRpcChannel channel = t.coprocessorService(ROW); CoprocessorRpcChannel channel = t.coprocessorService(ROW);
MultiRowMutationService.BlockingInterface service = MultiRowMutationService.BlockingInterface service =
MultiRowMutationService.newBlockingStub(channel); MultiRowMutationService.newBlockingStub(channel);
MultiRowMutationProtos.MutateRowsResponse response = MutateRowsResponse response = service.mutateRows(null, mrmBuilder.build());
service.mutateRows(null, mrmBuilder.build());
// Assert // Assert
assertTrue(response.getProcessed()); assertTrue(response.getProcessed());
@ -600,8 +594,7 @@ public class TestFromClientSide5 extends FromClientSideBase {
CoprocessorRpcChannel channel = t.coprocessorService(ROW); CoprocessorRpcChannel channel = t.coprocessorService(ROW);
MultiRowMutationService.BlockingInterface service = MultiRowMutationService.BlockingInterface service =
MultiRowMutationService.newBlockingStub(channel); MultiRowMutationService.newBlockingStub(channel);
MultiRowMutationProtos.MutateRowsResponse response = MutateRowsResponse response = service.mutateRows(null, mrmBuilder.build());
service.mutateRows(null, mrmBuilder.build());
// Assert // Assert
assertFalse(response.getProcessed()); assertFalse(response.getProcessed());