From 86ca65218d615dc9487a4974767290ee40e5fa85 Mon Sep 17 00:00:00 2001 From: kewang Date: Thu, 1 Feb 2018 18:22:05 +0800 Subject: [PATCH] HBASE-19912 Remove useless 'writeToWAL' flag of Region#checkAndRowMutate Signed-off-by: Michael Stack --- .../org/apache/hadoop/hbase/regionserver/HRegion.java | 10 ++++------ .../hadoop/hbase/regionserver/RSRpcServices.java | 2 +- .../org/apache/hadoop/hbase/regionserver/Region.java | 3 +-- .../apache/hadoop/hbase/regionserver/TestHRegion.java | 2 +- 4 files changed, 7 insertions(+), 10 deletions(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java index ae0f3d1e3dc..ecc9a7491b2 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java @@ -3919,16 +3919,14 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi throws IOException{ checkMutationType(mutation, row); return doCheckAndRowMutate(row, family, qualifier, op, comparator, null, - mutation, writeToWAL); + mutation); } @Override public boolean checkAndRowMutate(byte [] row, byte [] family, byte [] qualifier, - CompareOperator op, ByteArrayComparable comparator, RowMutations rm, - boolean writeToWAL) + CompareOperator op, ByteArrayComparable comparator, RowMutations rm) throws IOException { - return doCheckAndRowMutate(row, family, qualifier, op, comparator, rm, null, - writeToWAL); + return doCheckAndRowMutate(row, family, qualifier, op, comparator, rm, null); } /** @@ -3937,7 +3935,7 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi */ private boolean doCheckAndRowMutate(byte [] row, byte [] family, byte [] qualifier, CompareOperator op, ByteArrayComparable comparator, RowMutations rowMutations, - Mutation mutation, boolean writeToWAL) + Mutation mutation) throws IOException { // Could do the below checks but seems wacky with two callers only. Just comment out for now. // One caller passes a Mutation, the other passes RowMutation. Presume all good so we don't diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java index 5a015818ae7..b6ca599b4b9 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java @@ -618,7 +618,7 @@ public class RSRpcServices implements HBaseRPCErrorHandler, resultOrExceptionOrBuilder.build()); } return region.checkAndRowMutate(row, family, qualifier, op, - comparator, rm, Boolean.TRUE); + comparator, rm); } /** diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/Region.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/Region.java index 75f02a363c0..52d01fea1f0 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/Region.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/Region.java @@ -309,12 +309,11 @@ public interface Region extends ConfigurationObserver { * @param op the comparison operator * @param comparator * @param mutations - * @param writeToWAL * @return true if mutations were applied, false otherwise * @throws IOException */ boolean checkAndRowMutate(byte [] row, byte [] family, byte [] qualifier, CompareOperator op, - ByteArrayComparable comparator, RowMutations mutations, boolean writeToWAL) + ByteArrayComparable comparator, RowMutations mutations) throws IOException; /** diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHRegion.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHRegion.java index 04dcb926506..0d9db318b17 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHRegion.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHRegion.java @@ -6387,7 +6387,7 @@ public class TestHRegion { RowMutations rm = new RowMutations(row); rm.add(p); assertTrue(region.checkAndRowMutate(row, fam1, qual1, CompareOperator.EQUAL, - new BinaryComparator(qual1), rm, false)); + new BinaryComparator(qual1), rm)); result = region.get(new Get(row)); c = result.getColumnLatestCell(fam1, qual1); assertEquals(10L, c.getTimestamp());