This is an automated email from the ASF dual-hosted git repository.
brfrn169 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/master by this push:
new 4262887 HBASE-26002 MultiRowMutationEndpoint should return the result
of the conditional update (addendum)
4262887 is described below
commit 42628874324dcc869c9b8a6899e3aa016ac7391e
Author: Toshihiro Suzuki <[email protected]>
AuthorDate: Tue Jun 15 09:42:49 2021 +0900
HBASE-26002 MultiRowMutationEndpoint should return the result of the
conditional update (addendum)
Signed-off-by: Duo Zhang <[email protected]>
---
.../coprocessor/MultiRowMutationEndpoint.java | 2 +-
.../hadoop/hbase/client/TestFromClientSide5.java | 23 ++++++++--------------
2 files changed, 9 insertions(+), 16 deletions(-)
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/coprocessor/MultiRowMutationEndpoint.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/coprocessor/MultiRowMutationEndpoint.java
index 0a9b8fc..271ae87 100644
---
a/hbase-server/src/main/java/org/apache/hadoop/hbase/coprocessor/MultiRowMutationEndpoint.java
+++
b/hbase-server/src/main/java/org/apache/hadoop/hbase/coprocessor/MultiRowMutationEndpoint.java
@@ -96,7 +96,7 @@ import
org.apache.hadoop.hbase.shaded.protobuf.generated.MultiRowMutationProtos.
* MultiRowMutationService.BlockingInterface service =
* MultiRowMutationService.newBlockingStub(channel);
* 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
* boolean processed = response.getProcessed();
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestFromClientSide5.java
b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestFromClientSide5.java
index 8f938ee..f98d2ca 100644
---
a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestFromClientSide5.java
+++
b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestFromClientSide5.java
@@ -76,7 +76,6 @@ import org.apache.hadoop.hbase.regionserver.HRegion;
import org.apache.hadoop.hbase.regionserver.HRegionServer;
import org.apache.hadoop.hbase.regionserver.HStore;
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.LargeTests;
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.MultiRowMutationProtos.MultiRowMutationService;
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}.
@@ -302,8 +302,7 @@ public class TestFromClientSide5 extends FromClientSideBase
{
CoprocessorRpcChannel channel = t.coprocessorService(ROW);
MultiRowMutationService.BlockingInterface service =
MultiRowMutationService.newBlockingStub(channel);
- MultiRowMutationProtos.MutateRowsResponse response =
- service.mutateRows(null, mrmBuilder.build());
+ MutateRowsResponse response = service.mutateRows(null,
mrmBuilder.build());
// Assert
assertTrue(response.getProcessed());
@@ -353,8 +352,7 @@ public class TestFromClientSide5 extends FromClientSideBase
{
CoprocessorRpcChannel channel = t.coprocessorService(ROW);
MultiRowMutationService.BlockingInterface service =
MultiRowMutationService.newBlockingStub(channel);
- MultiRowMutationProtos.MutateRowsResponse response =
- service.mutateRows(null, mrmBuilder.build());
+ MutateRowsResponse response = service.mutateRows(null,
mrmBuilder.build());
// Assert
assertTrue(response.getProcessed());
@@ -400,8 +398,7 @@ public class TestFromClientSide5 extends FromClientSideBase
{
CoprocessorRpcChannel channel = t.coprocessorService(ROW);
MultiRowMutationService.BlockingInterface service =
MultiRowMutationService.newBlockingStub(channel);
- MultiRowMutationProtos.MutateRowsResponse response =
- service.mutateRows(null, mrmBuilder.build());
+ MutateRowsResponse response = service.mutateRows(null,
mrmBuilder.build());
// Assert
assertFalse(response.getProcessed());
@@ -449,8 +446,7 @@ public class TestFromClientSide5 extends FromClientSideBase
{
CoprocessorRpcChannel channel = t.coprocessorService(ROW);
MultiRowMutationService.BlockingInterface service =
MultiRowMutationService.newBlockingStub(channel);
- MultiRowMutationProtos.MutateRowsResponse response =
- service.mutateRows(null, mrmBuilder.build());
+ MutateRowsResponse response = service.mutateRows(null,
mrmBuilder.build());
// Assert
assertTrue(response.getProcessed());
@@ -498,8 +494,7 @@ public class TestFromClientSide5 extends FromClientSideBase
{
CoprocessorRpcChannel channel = t.coprocessorService(ROW);
MultiRowMutationService.BlockingInterface service =
MultiRowMutationService.newBlockingStub(channel);
- MultiRowMutationProtos.MutateRowsResponse response =
- service.mutateRows(null, mrmBuilder.build());
+ MutateRowsResponse response = service.mutateRows(null,
mrmBuilder.build());
// Assert
assertFalse(response.getProcessed());
@@ -549,8 +544,7 @@ public class TestFromClientSide5 extends FromClientSideBase
{
CoprocessorRpcChannel channel = t.coprocessorService(ROW);
MultiRowMutationService.BlockingInterface service =
MultiRowMutationService.newBlockingStub(channel);
- MultiRowMutationProtos.MutateRowsResponse response =
- service.mutateRows(null, mrmBuilder.build());
+ MutateRowsResponse response = service.mutateRows(null,
mrmBuilder.build());
// Assert
assertTrue(response.getProcessed());
@@ -600,8 +594,7 @@ public class TestFromClientSide5 extends FromClientSideBase
{
CoprocessorRpcChannel channel = t.coprocessorService(ROW);
MultiRowMutationService.BlockingInterface service =
MultiRowMutationService.newBlockingStub(channel);
- MultiRowMutationProtos.MutateRowsResponse response =
- service.mutateRows(null, mrmBuilder.build());
+ MutateRowsResponse response = service.mutateRows(null,
mrmBuilder.build());
// Assert
assertFalse(response.getProcessed());
