hbase git commit: HBASE-20823. Fix wrong param name in javadoc
Repository: hbase
Updated Branches:
refs/heads/master 619e0fdab -> 7e599428d
HBASE-20823. Fix wrong param name in javadoc
Signed-off-by: Reid Chan
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/7e599428
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/7e599428
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/7e599428
Branch: refs/heads/master
Commit: 7e599428d347e0b175495fbfdb04468948d2149a
Parents: 619e0fd
Author: jack-altiscale
Authored: Wed Jul 18 21:49:49 2018 -0700
Committer: Reid Chan
Committed: Thu Jul 19 18:26:18 2018 +0800
--
.../java/org/apache/hadoop/hbase/regionserver/HRegionServer.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/7e599428/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
--
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
index a43339b..85175be 100644
---
a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
+++
b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java
@@ -1270,7 +1270,7 @@ public class HRegionServer extends HasThread implements
/**
* Builds a {@link RegionSpaceUseReportRequest} protobuf message from the
region size map.
*
- * @param regionSizeStore The size in bytes of regions
+ * @param regionSizes The size in bytes of regions
* @return The corresponding protocol buffer message.
*/
RegionSpaceUseReportRequest buildRegionSpaceUseReportRequest(RegionSizeStore
regionSizes) {
hbase git commit: HBASE-20853 Polish "Add defaults to Table Interface so Implementors don't have to"
Repository: hbase
Updated Branches:
refs/heads/branch-2.0 f17c97bc1 -> ecb51e02e
HBASE-20853 Polish "Add defaults to Table Interface so Implementors don't have
to"
Signed-off-by: Chia-Ping Tsai
Signed-off-by: Michael Stack
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/ecb51e02
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/ecb51e02
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/ecb51e02
Branch: refs/heads/branch-2.0
Commit: ecb51e02ea69fc9f632739a96bd1e753b6c688ac
Parents: f17c97b
Author: Balazs Meszaros
Authored: Wed Jul 11 15:23:15 2018 +0200
Committer: Chia-Ping Tsai
Committed: Thu Jul 19 19:43:37 2018 +0800
--
.../org/apache/hadoop/hbase/client/Table.java | 69 ++--
1 file changed, 49 insertions(+), 20 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/ecb51e02/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Table.java
--
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Table.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Table.java
index 191d359..6f779cf 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Table.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Table.java
@@ -20,21 +20,24 @@ package org.apache.hadoop.hbase.client;
import java.io.Closeable;
import java.io.IOException;
+import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import org.apache.commons.lang3.NotImplementedException;
import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CompareOperator;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.io.TimeRange;
import org.apache.yetus.audience.InterfaceAudience;
+
import org.apache.hadoop.hbase.client.coprocessor.Batch;
import org.apache.hadoop.hbase.filter.CompareFilter;
import org.apache.hadoop.hbase.ipc.CoprocessorRpcChannel;
-
+import org.apache.hadoop.hbase.util.Bytes;
import com.google.protobuf.Descriptors;
import com.google.protobuf.Message;
import com.google.protobuf.Service;
@@ -73,7 +76,15 @@ public interface Table extends Closeable {
* use {@link #getDescriptor()}
*/
@Deprecated
- HTableDescriptor getTableDescriptor() throws IOException;
+ default HTableDescriptor getTableDescriptor() throws IOException {
+TableDescriptor descriptor = getDescriptor();
+
+if (descriptor instanceof HTableDescriptor) {
+ return (HTableDescriptor)descriptor;
+} else {
+ return new HTableDescriptor(descriptor);
+}
+ }
/**
* Gets the {@link org.apache.hadoop.hbase.client.TableDescriptor table
descriptor} for this table.
@@ -96,7 +107,7 @@ public interface Table extends Closeable {
* @throws IOException e
*/
default boolean exists(Get get) throws IOException {
-throw new NotImplementedException("Add an implementation!");
+return exists(Collections.singletonList(get))[0];
}
/**
@@ -176,7 +187,7 @@ public interface Table extends Closeable {
* @since 0.20.0
*/
default Result get(Get get) throws IOException {
-throw new NotImplementedException("Add an implementation!");
+return get(Collections.singletonList(get))[0];
}
/**
@@ -240,7 +251,6 @@ public interface Table extends Closeable {
throw new NotImplementedException("Add an implementation!");
}
-
/**
* Puts some data in the table.
*
@@ -249,7 +259,7 @@ public interface Table extends Closeable {
* @since 0.20.0
*/
default void put(Put put) throws IOException {
-throw new NotImplementedException("Add an implementation!");
+put(Collections.singletonList(put));
}
/**
@@ -289,7 +299,7 @@ public interface Table extends Closeable {
@Deprecated
default boolean checkAndPut(byte[] row, byte[] family, byte[] qualifier,
byte[] value, Put put)
throws IOException {
-throw new NotImplementedException("Add an implementation!");
+return checkAndPut(row, family, qualifier, CompareOperator.EQUAL, value,
put);
}
/**
@@ -315,7 +325,10 @@ public interface Table extends Closeable {
@Deprecated
default boolean checkAndPut(byte[] row, byte[] family, byte[] qualifier,
CompareFilter.CompareOp compareOp, byte[] value, Put put) throws
IOException {
-throw new NotImplementedException("Add an implementation!");
+RowMutations mutations = new RowMutations(put.getRow(), 1);
+mutations.add(put);
+
+return checkAndMutate(row, family, qualifier, compareOp, value, mutations);
}
/**
@@ -341,7 +354,10 @@ public interface Table
hbase git commit: HBASE-20853 Polish "Add defaults to Table Interface so Implementors don't have to"
Repository: hbase
Updated Branches:
refs/heads/branch-2 e464230bd -> 29f1352ed
HBASE-20853 Polish "Add defaults to Table Interface so Implementors don't have
to"
Signed-off-by: Chia-Ping Tsai
Signed-off-by: Michael Stack
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/29f1352e
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/29f1352e
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/29f1352e
Branch: refs/heads/branch-2
Commit: 29f1352edda7f3452d8efb39df3d1940dcc4011c
Parents: e464230
Author: Balazs Meszaros
Authored: Wed Jul 11 15:23:15 2018 +0200
Committer: Chia-Ping Tsai
Committed: Thu Jul 19 19:57:09 2018 +0800
--
.../org/apache/hadoop/hbase/client/Table.java | 69 ++--
1 file changed, 49 insertions(+), 20 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/29f1352e/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Table.java
--
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Table.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Table.java
index 191d359..6f779cf 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Table.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Table.java
@@ -20,21 +20,24 @@ package org.apache.hadoop.hbase.client;
import java.io.Closeable;
import java.io.IOException;
+import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import org.apache.commons.lang3.NotImplementedException;
import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CompareOperator;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.io.TimeRange;
import org.apache.yetus.audience.InterfaceAudience;
+
import org.apache.hadoop.hbase.client.coprocessor.Batch;
import org.apache.hadoop.hbase.filter.CompareFilter;
import org.apache.hadoop.hbase.ipc.CoprocessorRpcChannel;
-
+import org.apache.hadoop.hbase.util.Bytes;
import com.google.protobuf.Descriptors;
import com.google.protobuf.Message;
import com.google.protobuf.Service;
@@ -73,7 +76,15 @@ public interface Table extends Closeable {
* use {@link #getDescriptor()}
*/
@Deprecated
- HTableDescriptor getTableDescriptor() throws IOException;
+ default HTableDescriptor getTableDescriptor() throws IOException {
+TableDescriptor descriptor = getDescriptor();
+
+if (descriptor instanceof HTableDescriptor) {
+ return (HTableDescriptor)descriptor;
+} else {
+ return new HTableDescriptor(descriptor);
+}
+ }
/**
* Gets the {@link org.apache.hadoop.hbase.client.TableDescriptor table
descriptor} for this table.
@@ -96,7 +107,7 @@ public interface Table extends Closeable {
* @throws IOException e
*/
default boolean exists(Get get) throws IOException {
-throw new NotImplementedException("Add an implementation!");
+return exists(Collections.singletonList(get))[0];
}
/**
@@ -176,7 +187,7 @@ public interface Table extends Closeable {
* @since 0.20.0
*/
default Result get(Get get) throws IOException {
-throw new NotImplementedException("Add an implementation!");
+return get(Collections.singletonList(get))[0];
}
/**
@@ -240,7 +251,6 @@ public interface Table extends Closeable {
throw new NotImplementedException("Add an implementation!");
}
-
/**
* Puts some data in the table.
*
@@ -249,7 +259,7 @@ public interface Table extends Closeable {
* @since 0.20.0
*/
default void put(Put put) throws IOException {
-throw new NotImplementedException("Add an implementation!");
+put(Collections.singletonList(put));
}
/**
@@ -289,7 +299,7 @@ public interface Table extends Closeable {
@Deprecated
default boolean checkAndPut(byte[] row, byte[] family, byte[] qualifier,
byte[] value, Put put)
throws IOException {
-throw new NotImplementedException("Add an implementation!");
+return checkAndPut(row, family, qualifier, CompareOperator.EQUAL, value,
put);
}
/**
@@ -315,7 +325,10 @@ public interface Table extends Closeable {
@Deprecated
default boolean checkAndPut(byte[] row, byte[] family, byte[] qualifier,
CompareFilter.CompareOp compareOp, byte[] value, Put put) throws
IOException {
-throw new NotImplementedException("Add an implementation!");
+RowMutations mutations = new RowMutations(put.getRow(), 1);
+mutations.add(put);
+
+return checkAndMutate(row, family, qualifier, compareOp, value, mutations);
}
/**
@@ -341,7 +354,10 @@ public interface Table exte
hbase git commit: HBASE-20853 Polish "Add defaults to Table Interface so Implementors don't have to"
Repository: hbase
Updated Branches:
refs/heads/master 7e599428d -> 724e32349
HBASE-20853 Polish "Add defaults to Table Interface so Implementors don't have
to"
Signed-off-by: Chia-Ping Tsai
Signed-off-by: Michael Stack
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/724e3234
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/724e3234
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/724e3234
Branch: refs/heads/master
Commit: 724e323494da4f6562b98604560f854ebbd8229b
Parents: 7e59942
Author: Balazs Meszaros
Authored: Wed Jul 11 15:23:15 2018 +0200
Committer: Chia-Ping Tsai
Committed: Thu Jul 19 19:38:43 2018 +0800
--
.../org/apache/hadoop/hbase/client/Table.java | 69 ++--
1 file changed, 49 insertions(+), 20 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/724e3234/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Table.java
--
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Table.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Table.java
index 191d359..6f779cf 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Table.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Table.java
@@ -20,21 +20,24 @@ package org.apache.hadoop.hbase.client;
import java.io.Closeable;
import java.io.IOException;
+import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import org.apache.commons.lang3.NotImplementedException;
import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CompareOperator;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.io.TimeRange;
import org.apache.yetus.audience.InterfaceAudience;
+
import org.apache.hadoop.hbase.client.coprocessor.Batch;
import org.apache.hadoop.hbase.filter.CompareFilter;
import org.apache.hadoop.hbase.ipc.CoprocessorRpcChannel;
-
+import org.apache.hadoop.hbase.util.Bytes;
import com.google.protobuf.Descriptors;
import com.google.protobuf.Message;
import com.google.protobuf.Service;
@@ -73,7 +76,15 @@ public interface Table extends Closeable {
* use {@link #getDescriptor()}
*/
@Deprecated
- HTableDescriptor getTableDescriptor() throws IOException;
+ default HTableDescriptor getTableDescriptor() throws IOException {
+TableDescriptor descriptor = getDescriptor();
+
+if (descriptor instanceof HTableDescriptor) {
+ return (HTableDescriptor)descriptor;
+} else {
+ return new HTableDescriptor(descriptor);
+}
+ }
/**
* Gets the {@link org.apache.hadoop.hbase.client.TableDescriptor table
descriptor} for this table.
@@ -96,7 +107,7 @@ public interface Table extends Closeable {
* @throws IOException e
*/
default boolean exists(Get get) throws IOException {
-throw new NotImplementedException("Add an implementation!");
+return exists(Collections.singletonList(get))[0];
}
/**
@@ -176,7 +187,7 @@ public interface Table extends Closeable {
* @since 0.20.0
*/
default Result get(Get get) throws IOException {
-throw new NotImplementedException("Add an implementation!");
+return get(Collections.singletonList(get))[0];
}
/**
@@ -240,7 +251,6 @@ public interface Table extends Closeable {
throw new NotImplementedException("Add an implementation!");
}
-
/**
* Puts some data in the table.
*
@@ -249,7 +259,7 @@ public interface Table extends Closeable {
* @since 0.20.0
*/
default void put(Put put) throws IOException {
-throw new NotImplementedException("Add an implementation!");
+put(Collections.singletonList(put));
}
/**
@@ -289,7 +299,7 @@ public interface Table extends Closeable {
@Deprecated
default boolean checkAndPut(byte[] row, byte[] family, byte[] qualifier,
byte[] value, Put put)
throws IOException {
-throw new NotImplementedException("Add an implementation!");
+return checkAndPut(row, family, qualifier, CompareOperator.EQUAL, value,
put);
}
/**
@@ -315,7 +325,10 @@ public interface Table extends Closeable {
@Deprecated
default boolean checkAndPut(byte[] row, byte[] family, byte[] qualifier,
CompareFilter.CompareOp compareOp, byte[] value, Put put) throws
IOException {
-throw new NotImplementedException("Add an implementation!");
+RowMutations mutations = new RowMutations(put.getRow(), 1);
+mutations.add(put);
+
+return checkAndMutate(row, family, qualifier, compareOp, value, mutations);
}
/**
@@ -341,7 +354,10 @@ public interface Table extends
[2/2] hbase git commit: HBASE-20869 Endpoint-based Export use incorrect user to write to destination
HBASE-20869 Endpoint-based Export use incorrect user to write to destination
Signed-off-by: Chia-Ping Tsai
Signed-off-by: tedyu
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/8461e858
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/8461e858
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/8461e858
Branch: refs/heads/branch-2.1
Commit: 8461e858806bda23d27bcd4622d80b4679f83836
Parents: 36c4f62
Author: Wei-Chiu Chuang
Authored: Thu Jul 19 20:17:06 2018 +0800
Committer: Chia-Ping Tsai
Committed: Thu Jul 19 20:48:42 2018 +0800
--
.../org/apache/hadoop/hbase/coprocessor/Export.java | 13 ++---
.../hadoop/hbase/coprocessor/TestSecureExport.java | 16
2 files changed, 26 insertions(+), 3 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/8461e858/hbase-endpoint/src/main/java/org/apache/hadoop/hbase/coprocessor/Export.java
--
diff --git
a/hbase-endpoint/src/main/java/org/apache/hadoop/hbase/coprocessor/Export.java
b/hbase-endpoint/src/main/java/org/apache/hadoop/hbase/coprocessor/Export.java
index 6d6c1a6..b21d5c3 100644
---
a/hbase-endpoint/src/main/java/org/apache/hadoop/hbase/coprocessor/Export.java
+++
b/hbase-endpoint/src/main/java/org/apache/hadoop/hbase/coprocessor/Export.java
@@ -451,9 +451,16 @@ public class Export extends ExportProtos.ExportService
implements RegionCoproces
SecureWriter(final Configuration conf, final UserProvider userProvider,
final Token userToken, final List opts)
throws IOException {
- privilegedWriter = new PrivilegedWriter(getActiveUser(userProvider,
userToken),
-SequenceFile.createWriter(conf,
-opts.toArray(new SequenceFile.Writer.Option[opts.size()])));
+ User user = getActiveUser(userProvider, userToken);
+ try {
+SequenceFile.Writer sequenceFileWriter =
+user.runAs((PrivilegedExceptionAction) () ->
+SequenceFile.createWriter(conf,
+opts.toArray(new
SequenceFile.Writer.Option[opts.size()])));
+privilegedWriter = new PrivilegedWriter(user, sequenceFileWriter);
+ } catch (InterruptedException e) {
+throw new IOException(e);
+ }
}
void append(final Object key, final Object value) throws IOException {
http://git-wip-us.apache.org/repos/asf/hbase/blob/8461e858/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestSecureExport.java
--
diff --git
a/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestSecureExport.java
b/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestSecureExport.java
index 21f17f7..b2ca1d4 100644
---
a/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestSecureExport.java
+++
b/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestSecureExport.java
@@ -29,6 +29,7 @@ import java.util.List;
import java.util.Map;
import java.util.Properties;
import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.fs.permission.FsAction;
@@ -336,6 +337,21 @@ public class TestSecureExport {
LOG.error(ex.toString(), ex);
throw new Exception(ex);
} finally {
+if (fs.exists(new Path(openDir, "output"))) {
+ // if export completes successfully, every file under the output
directory should be
+ // owned by the current user, not the hbase service user.
+ FileStatus outputDirFileStatus = fs.getFileStatus(new Path(openDir,
"output"));
+ String currentUserName = User.getCurrent().getShortName();
+ assertEquals("Unexpected file owner", currentUserName,
outputDirFileStatus.getOwner());
+
+ FileStatus[] outputFileStatus = fs.listStatus(new Path(openDir,
"output"));
+ for (FileStatus fileStatus: outputFileStatus) {
+assertEquals("Unexpected file owner", currentUserName,
fileStatus.getOwner());
+ }
+} else {
+ LOG.info("output directory doesn't exist. Skip check");
+}
+
clearOutput(output);
}
};
hbase git commit: HBASE-20869 Endpoint-based Export use incorrect user to write to destination
Repository: hbase
Updated Branches:
refs/heads/branch-2.0 ecb51e02e -> 93e8acbe3
HBASE-20869 Endpoint-based Export use incorrect user to write to destination
Signed-off-by: Chia-Ping Tsai
Signed-off-by: tedyu
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/93e8acbe
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/93e8acbe
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/93e8acbe
Branch: refs/heads/branch-2.0
Commit: 93e8acbe34663fd13609e6eb1152ffe084d4d035
Parents: ecb51e0
Author: Wei-Chiu Chuang
Authored: Thu Jul 19 20:17:06 2018 +0800
Committer: Chia-Ping Tsai
Committed: Thu Jul 19 20:34:27 2018 +0800
--
.../org/apache/hadoop/hbase/coprocessor/Export.java | 13 ++---
.../hadoop/hbase/coprocessor/TestSecureExport.java | 16
2 files changed, 26 insertions(+), 3 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/93e8acbe/hbase-endpoint/src/main/java/org/apache/hadoop/hbase/coprocessor/Export.java
--
diff --git
a/hbase-endpoint/src/main/java/org/apache/hadoop/hbase/coprocessor/Export.java
b/hbase-endpoint/src/main/java/org/apache/hadoop/hbase/coprocessor/Export.java
index 6d6c1a6..b21d5c3 100644
---
a/hbase-endpoint/src/main/java/org/apache/hadoop/hbase/coprocessor/Export.java
+++
b/hbase-endpoint/src/main/java/org/apache/hadoop/hbase/coprocessor/Export.java
@@ -451,9 +451,16 @@ public class Export extends ExportProtos.ExportService
implements RegionCoproces
SecureWriter(final Configuration conf, final UserProvider userProvider,
final Token userToken, final List opts)
throws IOException {
- privilegedWriter = new PrivilegedWriter(getActiveUser(userProvider,
userToken),
-SequenceFile.createWriter(conf,
-opts.toArray(new SequenceFile.Writer.Option[opts.size()])));
+ User user = getActiveUser(userProvider, userToken);
+ try {
+SequenceFile.Writer sequenceFileWriter =
+user.runAs((PrivilegedExceptionAction) () ->
+SequenceFile.createWriter(conf,
+opts.toArray(new
SequenceFile.Writer.Option[opts.size()])));
+privilegedWriter = new PrivilegedWriter(user, sequenceFileWriter);
+ } catch (InterruptedException e) {
+throw new IOException(e);
+ }
}
void append(final Object key, final Object value) throws IOException {
http://git-wip-us.apache.org/repos/asf/hbase/blob/93e8acbe/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestSecureExport.java
--
diff --git
a/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestSecureExport.java
b/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestSecureExport.java
index 21f17f7..b2ca1d4 100644
---
a/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestSecureExport.java
+++
b/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestSecureExport.java
@@ -29,6 +29,7 @@ import java.util.List;
import java.util.Map;
import java.util.Properties;
import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.fs.permission.FsAction;
@@ -336,6 +337,21 @@ public class TestSecureExport {
LOG.error(ex.toString(), ex);
throw new Exception(ex);
} finally {
+if (fs.exists(new Path(openDir, "output"))) {
+ // if export completes successfully, every file under the output
directory should be
+ // owned by the current user, not the hbase service user.
+ FileStatus outputDirFileStatus = fs.getFileStatus(new Path(openDir,
"output"));
+ String currentUserName = User.getCurrent().getShortName();
+ assertEquals("Unexpected file owner", currentUserName,
outputDirFileStatus.getOwner());
+
+ FileStatus[] outputFileStatus = fs.listStatus(new Path(openDir,
"output"));
+ for (FileStatus fileStatus: outputFileStatus) {
+assertEquals("Unexpected file owner", currentUserName,
fileStatus.getOwner());
+ }
+} else {
+ LOG.info("output directory doesn't exist. Skip check");
+}
+
clearOutput(output);
}
};
[1/2] hbase git commit: HBASE-20853 Polish "Add defaults to Table Interface so Implementors don't have to"
Repository: hbase
Updated Branches:
refs/heads/branch-2.1 9ac26b80b -> 8461e8588
HBASE-20853 Polish "Add defaults to Table Interface so Implementors don't have
to"
Signed-off-by: Chia-Ping Tsai
Signed-off-by: Michael Stack
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/36c4f62d
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/36c4f62d
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/36c4f62d
Branch: refs/heads/branch-2.1
Commit: 36c4f62dafcede4cae20c939f72fa11443ab5bd6
Parents: 9ac26b8
Author: Balazs Meszaros
Authored: Wed Jul 11 15:23:15 2018 +0200
Committer: Chia-Ping Tsai
Committed: Thu Jul 19 20:48:32 2018 +0800
--
.../org/apache/hadoop/hbase/client/Table.java | 69 ++--
1 file changed, 49 insertions(+), 20 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/36c4f62d/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Table.java
--
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Table.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Table.java
index 191d359..6f779cf 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Table.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Table.java
@@ -20,21 +20,24 @@ package org.apache.hadoop.hbase.client;
import java.io.Closeable;
import java.io.IOException;
+import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import org.apache.commons.lang3.NotImplementedException;
import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CompareOperator;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.io.TimeRange;
import org.apache.yetus.audience.InterfaceAudience;
+
import org.apache.hadoop.hbase.client.coprocessor.Batch;
import org.apache.hadoop.hbase.filter.CompareFilter;
import org.apache.hadoop.hbase.ipc.CoprocessorRpcChannel;
-
+import org.apache.hadoop.hbase.util.Bytes;
import com.google.protobuf.Descriptors;
import com.google.protobuf.Message;
import com.google.protobuf.Service;
@@ -73,7 +76,15 @@ public interface Table extends Closeable {
* use {@link #getDescriptor()}
*/
@Deprecated
- HTableDescriptor getTableDescriptor() throws IOException;
+ default HTableDescriptor getTableDescriptor() throws IOException {
+TableDescriptor descriptor = getDescriptor();
+
+if (descriptor instanceof HTableDescriptor) {
+ return (HTableDescriptor)descriptor;
+} else {
+ return new HTableDescriptor(descriptor);
+}
+ }
/**
* Gets the {@link org.apache.hadoop.hbase.client.TableDescriptor table
descriptor} for this table.
@@ -96,7 +107,7 @@ public interface Table extends Closeable {
* @throws IOException e
*/
default boolean exists(Get get) throws IOException {
-throw new NotImplementedException("Add an implementation!");
+return exists(Collections.singletonList(get))[0];
}
/**
@@ -176,7 +187,7 @@ public interface Table extends Closeable {
* @since 0.20.0
*/
default Result get(Get get) throws IOException {
-throw new NotImplementedException("Add an implementation!");
+return get(Collections.singletonList(get))[0];
}
/**
@@ -240,7 +251,6 @@ public interface Table extends Closeable {
throw new NotImplementedException("Add an implementation!");
}
-
/**
* Puts some data in the table.
*
@@ -249,7 +259,7 @@ public interface Table extends Closeable {
* @since 0.20.0
*/
default void put(Put put) throws IOException {
-throw new NotImplementedException("Add an implementation!");
+put(Collections.singletonList(put));
}
/**
@@ -289,7 +299,7 @@ public interface Table extends Closeable {
@Deprecated
default boolean checkAndPut(byte[] row, byte[] family, byte[] qualifier,
byte[] value, Put put)
throws IOException {
-throw new NotImplementedException("Add an implementation!");
+return checkAndPut(row, family, qualifier, CompareOperator.EQUAL, value,
put);
}
/**
@@ -315,7 +325,10 @@ public interface Table extends Closeable {
@Deprecated
default boolean checkAndPut(byte[] row, byte[] family, byte[] qualifier,
CompareFilter.CompareOp compareOp, byte[] value, Put put) throws
IOException {
-throw new NotImplementedException("Add an implementation!");
+RowMutations mutations = new RowMutations(put.getRow(), 1);
+mutations.add(put);
+
+return checkAndMutate(row, family, qualifier, compareOp, value, mutations);
}
/**
@@ -341,7 +354,10 @@ public interface Table
hbase git commit: HBASE-20869 Endpoint-based Export use incorrect user to write to destination
Repository: hbase
Updated Branches:
refs/heads/branch-2 29f1352ed -> 4259da722
HBASE-20869 Endpoint-based Export use incorrect user to write to destination
Signed-off-by: Chia-Ping Tsai
Signed-off-by: tedyu
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/4259da72
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/4259da72
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/4259da72
Branch: refs/heads/branch-2
Commit: 4259da722e1982ecf91ec2cb9ded9671349cd56a
Parents: 29f1352
Author: Wei-Chiu Chuang
Authored: Thu Jul 19 20:17:06 2018 +0800
Committer: Chia-Ping Tsai
Committed: Thu Jul 19 20:18:34 2018 +0800
--
.../org/apache/hadoop/hbase/coprocessor/Export.java | 13 ++---
.../hadoop/hbase/coprocessor/TestSecureExport.java | 16
2 files changed, 26 insertions(+), 3 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/4259da72/hbase-endpoint/src/main/java/org/apache/hadoop/hbase/coprocessor/Export.java
--
diff --git
a/hbase-endpoint/src/main/java/org/apache/hadoop/hbase/coprocessor/Export.java
b/hbase-endpoint/src/main/java/org/apache/hadoop/hbase/coprocessor/Export.java
index 6d6c1a6..b21d5c3 100644
---
a/hbase-endpoint/src/main/java/org/apache/hadoop/hbase/coprocessor/Export.java
+++
b/hbase-endpoint/src/main/java/org/apache/hadoop/hbase/coprocessor/Export.java
@@ -451,9 +451,16 @@ public class Export extends ExportProtos.ExportService
implements RegionCoproces
SecureWriter(final Configuration conf, final UserProvider userProvider,
final Token userToken, final List opts)
throws IOException {
- privilegedWriter = new PrivilegedWriter(getActiveUser(userProvider,
userToken),
-SequenceFile.createWriter(conf,
-opts.toArray(new SequenceFile.Writer.Option[opts.size()])));
+ User user = getActiveUser(userProvider, userToken);
+ try {
+SequenceFile.Writer sequenceFileWriter =
+user.runAs((PrivilegedExceptionAction) () ->
+SequenceFile.createWriter(conf,
+opts.toArray(new
SequenceFile.Writer.Option[opts.size()])));
+privilegedWriter = new PrivilegedWriter(user, sequenceFileWriter);
+ } catch (InterruptedException e) {
+throw new IOException(e);
+ }
}
void append(final Object key, final Object value) throws IOException {
http://git-wip-us.apache.org/repos/asf/hbase/blob/4259da72/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestSecureExport.java
--
diff --git
a/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestSecureExport.java
b/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestSecureExport.java
index 21f17f7..b2ca1d4 100644
---
a/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestSecureExport.java
+++
b/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestSecureExport.java
@@ -29,6 +29,7 @@ import java.util.List;
import java.util.Map;
import java.util.Properties;
import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.fs.permission.FsAction;
@@ -336,6 +337,21 @@ public class TestSecureExport {
LOG.error(ex.toString(), ex);
throw new Exception(ex);
} finally {
+if (fs.exists(new Path(openDir, "output"))) {
+ // if export completes successfully, every file under the output
directory should be
+ // owned by the current user, not the hbase service user.
+ FileStatus outputDirFileStatus = fs.getFileStatus(new Path(openDir,
"output"));
+ String currentUserName = User.getCurrent().getShortName();
+ assertEquals("Unexpected file owner", currentUserName,
outputDirFileStatus.getOwner());
+
+ FileStatus[] outputFileStatus = fs.listStatus(new Path(openDir,
"output"));
+ for (FileStatus fileStatus: outputFileStatus) {
+assertEquals("Unexpected file owner", currentUserName,
fileStatus.getOwner());
+ }
+} else {
+ LOG.info("output directory doesn't exist. Skip check");
+}
+
clearOutput(output);
}
};
hbase git commit: HBASE-20869 Endpoint-based Export use incorrect user to write to destination
Repository: hbase
Updated Branches:
refs/heads/master 724e32349 -> 1ed58e41c
HBASE-20869 Endpoint-based Export use incorrect user to write to destination
Signed-off-by: Chia-Ping Tsai
Signed-off-by: tedyu
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/1ed58e41
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/1ed58e41
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/1ed58e41
Branch: refs/heads/master
Commit: 1ed58e41cce526e93d8da66c9571f71d11d94e8f
Parents: 724e323
Author: Wei-Chiu Chuang
Authored: Thu Jul 19 20:17:06 2018 +0800
Committer: Chia-Ping Tsai
Committed: Thu Jul 19 20:29:55 2018 +0800
--
.../org/apache/hadoop/hbase/coprocessor/Export.java | 13 ++---
.../hadoop/hbase/coprocessor/TestSecureExport.java | 16
2 files changed, 26 insertions(+), 3 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/1ed58e41/hbase-endpoint/src/main/java/org/apache/hadoop/hbase/coprocessor/Export.java
--
diff --git
a/hbase-endpoint/src/main/java/org/apache/hadoop/hbase/coprocessor/Export.java
b/hbase-endpoint/src/main/java/org/apache/hadoop/hbase/coprocessor/Export.java
index 6d6c1a6..b21d5c3 100644
---
a/hbase-endpoint/src/main/java/org/apache/hadoop/hbase/coprocessor/Export.java
+++
b/hbase-endpoint/src/main/java/org/apache/hadoop/hbase/coprocessor/Export.java
@@ -451,9 +451,16 @@ public class Export extends ExportProtos.ExportService
implements RegionCoproces
SecureWriter(final Configuration conf, final UserProvider userProvider,
final Token userToken, final List opts)
throws IOException {
- privilegedWriter = new PrivilegedWriter(getActiveUser(userProvider,
userToken),
-SequenceFile.createWriter(conf,
-opts.toArray(new SequenceFile.Writer.Option[opts.size()])));
+ User user = getActiveUser(userProvider, userToken);
+ try {
+SequenceFile.Writer sequenceFileWriter =
+user.runAs((PrivilegedExceptionAction) () ->
+SequenceFile.createWriter(conf,
+opts.toArray(new
SequenceFile.Writer.Option[opts.size()])));
+privilegedWriter = new PrivilegedWriter(user, sequenceFileWriter);
+ } catch (InterruptedException e) {
+throw new IOException(e);
+ }
}
void append(final Object key, final Object value) throws IOException {
http://git-wip-us.apache.org/repos/asf/hbase/blob/1ed58e41/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestSecureExport.java
--
diff --git
a/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestSecureExport.java
b/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestSecureExport.java
index 21f17f7..b2ca1d4 100644
---
a/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestSecureExport.java
+++
b/hbase-endpoint/src/test/java/org/apache/hadoop/hbase/coprocessor/TestSecureExport.java
@@ -29,6 +29,7 @@ import java.util.List;
import java.util.Map;
import java.util.Properties;
import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.fs.permission.FsAction;
@@ -336,6 +337,21 @@ public class TestSecureExport {
LOG.error(ex.toString(), ex);
throw new Exception(ex);
} finally {
+if (fs.exists(new Path(openDir, "output"))) {
+ // if export completes successfully, every file under the output
directory should be
+ // owned by the current user, not the hbase service user.
+ FileStatus outputDirFileStatus = fs.getFileStatus(new Path(openDir,
"output"));
+ String currentUserName = User.getCurrent().getShortName();
+ assertEquals("Unexpected file owner", currentUserName,
outputDirFileStatus.getOwner());
+
+ FileStatus[] outputFileStatus = fs.listStatus(new Path(openDir,
"output"));
+ for (FileStatus fileStatus: outputFileStatus) {
+assertEquals("Unexpected file owner", currentUserName,
fileStatus.getOwner());
+ }
+} else {
+ LOG.info("output directory doesn't exist. Skip check");
+}
+
clearOutput(output);
}
};
hbase git commit: HBASE-6028 Start/Stop compactions at region server level
Repository: hbase
Updated Branches:
refs/heads/branch-2 4259da722 -> 35a3c605f
HBASE-6028 Start/Stop compactions at region server level
Add switching on/off of compactions.
Switching off compactions will also interrupt any currently ongoing compactions.
Adds a "compaction_switch" to hbase shell. Switching off compactions will
interrupt any currently ongoing compactions. State set from shell will be
lost on restart. To persist the changes across region servers modify
hbase.regionserver.compaction.enabled in hbase-site.xml and restart.
Signed-off-by: Umesh Agashe
Signed-off-by: Michael Stack
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/35a3c605
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/35a3c605
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/35a3c605
Branch: refs/heads/branch-2
Commit: 35a3c605f2e9edb7e5e1b21d3f15ef351fca0432
Parents: 4259da7
Author: Mohit Goel
Authored: Thu Jun 7 15:11:28 2018 -0700
Committer: Michael Stack
Committed: Thu Jul 19 06:20:12 2018 -0700
--
.../org/apache/hadoop/hbase/client/Admin.java | 13 ++
.../apache/hadoop/hbase/client/AsyncAdmin.java | 13 ++
.../hadoop/hbase/client/AsyncHBaseAdmin.java| 6 +
.../apache/hadoop/hbase/client/HBaseAdmin.java | 47 +++
.../hadoop/hbase/client/RawAsyncHBaseAdmin.java | 82 +
.../src/main/resources/hbase-default.xml| 7 ++
.../src/main/protobuf/Admin.proto | 11 ++
.../hadoop/hbase/regionserver/CompactSplit.java | 123 ++-
.../hadoop/hbase/regionserver/HRegion.java | 6 +-
.../hbase/regionserver/RSRpcServices.java | 22
.../hadoop/hbase/regionserver/Region.java | 2 +-
.../compactions/CompactionRequester.java| 6 +
.../hbase/client/TestAsyncRegionAdminApi.java | 38 ++
.../hadoop/hbase/master/MockRegionServer.java | 8 ++
.../hbase/regionserver/TestCompaction.java | 85 +
hbase-shell/src/main/ruby/hbase/admin.rb| 13 ++
hbase-shell/src/main/ruby/shell.rb | 1 +
.../ruby/shell/commands/compaction_switch.rb| 52
src/main/asciidoc/_chapters/architecture.adoc | 8 ++
19 files changed, 508 insertions(+), 35 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/35a3c605/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Admin.java
--
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Admin.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Admin.java
index 331f2d1..01ebb66 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Admin.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Admin.java
@@ -996,6 +996,19 @@ public interface Admin extends Abortable, Closeable {
}
/**
+ * Turn the compaction on or off. Disabling compactions will also interrupt
any currently ongoing
+ * compactions. This state is ephemeral. The setting will be lost on
restart. Compaction
+ * can also be enabled/disabled by modifying configuration
hbase.regionserver.compaction.enabled
+ * in hbase-site.xml.
+ *
+ * @param switchState Set to true to enable,
false to disable.
+ * @param serverNamesList list of region servers.
+ * @return Previous compaction states for region servers
+ */
+ Map compactionSwitch(boolean switchState, List
serverNamesList)
+ throws IOException;
+
+ /**
* Compact all regions on the region server. Asynchronous operation in that
this method requests
* that a Compaction run and then it returns. It does not wait on the
completion of Compaction (it
* can take a while).
http://git-wip-us.apache.org/repos/asf/hbase/blob/35a3c605/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdmin.java
--
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdmin.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdmin.java
index 8141e74..0e47de8 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdmin.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdmin.java
@@ -1240,4 +1240,17 @@ public interface AsyncAdmin {
*/
CompletableFuture cloneTableSchema(final TableName tableName,
final TableName newTableName, final boolean preserveSplits);
+
+ /**
+ * Turn the compaction on or off. Disabling compactions will also interrupt
any currently ongoing
+ * compactions. This state is ephemeral. The setting will be lost on
restart. Compaction
+ * can also be enabled/disabled by modifying configuration
hbase.regionserver.compaction.enabled
+ * in hbase-site.xml
hbase git commit: HBASE-6028 Start/Stop compactions at region server level
Repository: hbase
Updated Branches:
refs/heads/master 1ed58e41c -> 950d6e6fb
HBASE-6028 Start/Stop compactions at region server level
Add switching on/off of compactions.
Switching off compactions will also interrupt any currently ongoing compactions.
Adds a "compaction_switch" to hbase shell. Switching off compactions will
interrupt any currently ongoing compactions. State set from shell will be
lost on restart. To persist the changes across region servers modify
hbase.regionserver.compaction.enabled in hbase-site.xml and restart.
Signed-off-by: Umesh Agashe
Signed-off-by: Michael Stack
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/950d6e6f
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/950d6e6f
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/950d6e6f
Branch: refs/heads/master
Commit: 950d6e6fb0fdcf923aea66e17e617c06ecd5a628
Parents: 1ed58e4
Author: Mohit Goel
Authored: Thu Jun 7 15:11:28 2018 -0700
Committer: Michael Stack
Committed: Thu Jul 19 06:20:44 2018 -0700
--
.../org/apache/hadoop/hbase/client/Admin.java | 13 ++
.../apache/hadoop/hbase/client/AsyncAdmin.java | 13 ++
.../hadoop/hbase/client/AsyncHBaseAdmin.java| 6 +
.../apache/hadoop/hbase/client/HBaseAdmin.java | 47 +++
.../hadoop/hbase/client/RawAsyncHBaseAdmin.java | 82 +
.../src/main/resources/hbase-default.xml| 7 ++
.../src/main/protobuf/Admin.proto | 11 ++
.../hadoop/hbase/regionserver/CompactSplit.java | 123 ++-
.../hadoop/hbase/regionserver/HRegion.java | 6 +-
.../hbase/regionserver/RSRpcServices.java | 22
.../hadoop/hbase/regionserver/Region.java | 2 +-
.../compactions/CompactionRequester.java| 6 +
.../hbase/client/TestAsyncRegionAdminApi.java | 38 ++
.../hadoop/hbase/master/MockRegionServer.java | 8 ++
.../hbase/regionserver/TestCompaction.java | 85 +
hbase-shell/src/main/ruby/hbase/admin.rb| 13 ++
hbase-shell/src/main/ruby/shell.rb | 1 +
.../ruby/shell/commands/compaction_switch.rb| 52
src/main/asciidoc/_chapters/architecture.adoc | 8 ++
19 files changed, 508 insertions(+), 35 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/950d6e6f/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Admin.java
--
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Admin.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Admin.java
index 39542e4..a43a0b2 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Admin.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/Admin.java
@@ -997,6 +997,19 @@ public interface Admin extends Abortable, Closeable {
}
/**
+ * Turn the compaction on or off. Disabling compactions will also interrupt
any currently ongoing
+ * compactions. This state is ephemeral. The setting will be lost on
restart. Compaction
+ * can also be enabled/disabled by modifying configuration
hbase.regionserver.compaction.enabled
+ * in hbase-site.xml.
+ *
+ * @param switchState Set to true to enable,
false to disable.
+ * @param serverNamesList list of region servers.
+ * @return Previous compaction states for region servers
+ */
+ Map compactionSwitch(boolean switchState, List
serverNamesList)
+ throws IOException;
+
+ /**
* Compact all regions on the region server. Asynchronous operation in that
this method requests
* that a Compaction run and then it returns. It does not wait on the
completion of Compaction (it
* can take a while).
http://git-wip-us.apache.org/repos/asf/hbase/blob/950d6e6f/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdmin.java
--
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdmin.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdmin.java
index 65cccf7..739c78a 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdmin.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdmin.java
@@ -1271,4 +1271,17 @@ public interface AsyncAdmin {
*/
CompletableFuture cloneTableSchema(final TableName tableName,
final TableName newTableName, final boolean preserveSplits);
+
+ /**
+ * Turn the compaction on or off. Disabling compactions will also interrupt
any currently ongoing
+ * compactions. This state is ephemeral. The setting will be lost on
restart. Compaction
+ * can also be enabled/disabled by modifying configuration
hbase.regionserver.compaction.enabled
+ * in hbase-site.xml.
+
hbase git commit: HBASE-20909 Add 2.1.0 to the download page
Repository: hbase Updated Branches: refs/heads/master 950d6e6fb -> c92cda842 HBASE-20909 Add 2.1.0 to the download page Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/c92cda84 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/c92cda84 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/c92cda84 Branch: refs/heads/master Commit: c92cda8420e5163d9486de9fe84fe82bc090b9bc Parents: 950d6e6 Author: zhangduo Authored: Thu Jul 19 21:29:46 2018 +0800 Committer: zhangduo Committed: Thu Jul 19 22:51:55 2018 +0800 -- src/site/xdoc/downloads.xml | 27 ++- 1 file changed, 26 insertions(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/c92cda84/src/site/xdoc/downloads.xml -- diff --git a/src/site/xdoc/downloads.xml b/src/site/xdoc/downloads.xml index a112528..8b35ac6 100644 --- a/src/site/xdoc/downloads.xml +++ b/src/site/xdoc/downloads.xml @@ -45,6 +45,31 @@ under the License. +2.1.0 + + +2018/07/18 + + +https://apache.org/dist/hbase/2.1.0/compatibility_report_2.0.0vs2.1.0.html";>2.0.0 vs 2.1.0 + + +https://apache.org/dist/hbase/2.1.0/CHANGES.md";>Changes + + +https://apache.org/dist/hbase/2.1.0/RELEASENOTES.md";>Release Notes + + +https://git-wip-us.apache.org/repos/asf?p=hbase.git;a=commit;h=e1673bb0bbfea21d6e5dba73e013b09b8b49b89b";>e1673bb0bbfea21d6e5dba73e013b09b8b49b89b + + +https://www.apache.org/dyn/closer.lua/hbase/2.1.0/hbase-2.1.0-src.tar.gz";>src (https://apache.org/dist/hbase/2.1.0/hbase-2.1.0-src.tar.gz.sha512";>sha512 https://apache.org/dist/hbase/2.1.0/hbase-2.1.0-src.tar.gz.asc";>asc) +https://www.apache.org/dyn/closer.lua/hbase/2.1.0/hbase-2.1.0-bin.tar.gz";>bin (https://apache.org/dist/hbase/2.1.0/hbase-2.1.0-bin.tar.gz.sha512";>sha512 https://apache.org/dist/hbase/2.1.0/hbase-2.1.0-bin.tar.gz.asc";>asc) +https://www.apache.org/dyn/closer.lua/hbase/2.1.0/hbase-2.1.0-client-bin.tar.gz";>client-bin (https://apache.org/dist/hbase/2.1.0/hbase-2.1.0-client-bin.tar.gz.sha512";>sha512 https://apache.org/dist/hbase/2.1.0/hbase-2.1.0-client-bin.tar.gz.asc";>asc) + + + + 2.0.1 @@ -64,7 +89,7 @@ under the License. https://www.apache.org/dyn/closer.lua/hbase/2.0.1/hbase-2.0.1-src.tar.gz";>src (https://apache.org/dist/hbase/2.0.1/hbase-2.0.1-src.tar.gz.sha512";>sha512 https://apache.org/dist/hbase/2.0.1/hbase-2.0.1-src.tar.gz.asc";>asc) -https://www.apache.org/dyn/closer.lua/hbase/2.0.1/hbase-2.0.1-bin.tar.gz";>bin (https://apache.org/dist/hbase/2.0.1/hbase-2.0.1-bin.tar.gz.sha512";>sha512 https://apache.org/dist/hbase/2.0.1/hbase-2.0..-bin.tar.gz.asc";>asc) +https://www.apache.org/dyn/closer.lua/hbase/2.0.1/hbase-2.0.1-bin.tar.gz";>bin (https://apache.org/dist/hbase/2.0.1/hbase-2.0.1-bin.tar.gz.sha512";>sha512 https://apache.org/dist/hbase/2.0.1/hbase-2.0.1-bin.tar.gz.asc";>asc)
hbase git commit: HBASE-20855 PeerConfigTracker only supporting one listener will cause problem when there is a recovered replication queue
Repository: hbase
Updated Branches:
refs/heads/branch-1 61288f843 -> 15ed2e86e
HBASE-20855 PeerConfigTracker only supporting one listener will cause problem
when there is a recovered replication queue
Signed-off-by: tedyu
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/15ed2e86
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/15ed2e86
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/15ed2e86
Branch: refs/heads/branch-1
Commit: 15ed2e86e143612cc99af98a40d2905892c7ec81
Parents: 61288f8
Author: jingyuntian
Authored: Thu Jul 19 11:51:54 2018 +0800
Committer: tedyu
Committed: Thu Jul 19 08:43:23 2018 -0700
--
.../hbase/replication/ReplicationPeer.java | 6 ++
.../replication/ReplicationPeerZKImpl.java | 32 +-
.../replication/BaseReplicationEndpoint.java| 6 ++
.../replication/HBaseReplicationEndpoint.java | 1 +
.../HBaseInterClusterReplicationEndpoint.java | 1 +
.../regionserver/ReplicationSource.java | 4 +
.../TestReplicationConfigTracker.java | 100 +++
7 files changed, 145 insertions(+), 5 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/15ed2e86/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeer.java
--
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeer.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeer.java
index 200d81c..a0e758f 100644
---
a/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeer.java
+++
b/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeer.java
@@ -81,4 +81,10 @@ public interface ReplicationPeer {
* @param listener Listener for config changes, usually a replication
endpoint
*/
void trackPeerConfigChanges(ReplicationPeerConfigListener listener);
+
+ /**
+ * Remove a listener when it is closed or terminated
+ * @param listener Listener for config changes, usually a replication
endpoint
+ */
+ void removeListenerOfPeerConfig(ReplicationPeerConfigListener listener);
}
http://git-wip-us.apache.org/repos/asf/hbase/blob/15ed2e86/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeerZKImpl.java
--
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeerZKImpl.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeerZKImpl.java
index b79a982..57b118d 100644
---
a/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeerZKImpl.java
+++
b/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeerZKImpl.java
@@ -21,8 +21,10 @@ package org.apache.hadoop.hbase.replication;
import java.io.Closeable;
import java.io.IOException;
import java.util.HashMap;
+import java.util.HashSet;
import java.util.List;
import java.util.Map;
+import java.util.Set;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
@@ -172,11 +174,22 @@ public class ReplicationPeerZKImpl extends
ReplicationStateZKBase implements Rep
@Override
public void trackPeerConfigChanges(ReplicationPeerConfigListener listener) {
if (this.peerConfigTracker != null){
- this.peerConfigTracker.setListener(listener);
+ this.peerConfigTracker.addListener(listener);
}
}
@Override
+ public void removeListenerOfPeerConfig(ReplicationPeerConfigListener
listener) {
+if (this.peerConfigTracker != null){
+ this.peerConfigTracker.removeListener(listener);
+}
+ }
+
+ PeerConfigTracker getPeerConfigTracker() {
+return this.peerConfigTracker;
+ }
+
+ @Override
public void abort(String why, Throwable e) {
LOG.fatal("The ReplicationPeer corresponding to peer " + peerConfig
+ " was aborted for the following reason(s):" + why, e);
@@ -275,15 +288,24 @@ public class ReplicationPeerZKImpl extends
ReplicationStateZKBase implements Rep
*/
public class PeerConfigTracker extends ZooKeeperNodeTracker {
-private ReplicationPeerConfigListener listener;
+private Set listeners;
public PeerConfigTracker(String peerConfigNode, ZooKeeperWatcher watcher,
Abortable abortable) {
super(watcher, peerConfigNode, abortable);
+ listeners = new HashSet<>();
+}
+
+public synchronized void addListener(ReplicationPeerConfigListener
listener){
+ listeners.add(listener);
+}
+
+Set getListeners(){
+ return this.listeners;
}
-public synchronized void setListener(ReplicationPeerConfigListener
listener){
- this.lis
hbase git commit: HBASE-20855 PeerConfigTracker only supporting one listener will cause problem when there is a recovered replication queue
Repository: hbase
Updated Branches:
refs/heads/branch-1.4 2cf636af5 -> e142d0560
HBASE-20855 PeerConfigTracker only supporting one listener will cause problem
when there is a recovered replication queue
Signed-off-by: tedyu
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/e142d056
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/e142d056
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/e142d056
Branch: refs/heads/branch-1.4
Commit: e142d056093e2f78c6c5ad6f6b98a66831ac431f
Parents: 2cf636a
Author: jingyuntian
Authored: Thu Jul 19 11:51:54 2018 +0800
Committer: tedyu
Committed: Thu Jul 19 08:48:34 2018 -0700
--
.../hbase/replication/ReplicationPeer.java | 6 ++
.../replication/ReplicationPeerZKImpl.java | 32 +-
.../replication/BaseReplicationEndpoint.java| 6 ++
.../replication/HBaseReplicationEndpoint.java | 1 +
.../HBaseInterClusterReplicationEndpoint.java | 1 +
.../regionserver/ReplicationSource.java | 4 +
.../TestReplicationConfigTracker.java | 100 +++
7 files changed, 145 insertions(+), 5 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/e142d056/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeer.java
--
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeer.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeer.java
index 200d81c..a0e758f 100644
---
a/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeer.java
+++
b/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeer.java
@@ -81,4 +81,10 @@ public interface ReplicationPeer {
* @param listener Listener for config changes, usually a replication
endpoint
*/
void trackPeerConfigChanges(ReplicationPeerConfigListener listener);
+
+ /**
+ * Remove a listener when it is closed or terminated
+ * @param listener Listener for config changes, usually a replication
endpoint
+ */
+ void removeListenerOfPeerConfig(ReplicationPeerConfigListener listener);
}
http://git-wip-us.apache.org/repos/asf/hbase/blob/e142d056/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeerZKImpl.java
--
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeerZKImpl.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeerZKImpl.java
index b79a982..57b118d 100644
---
a/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeerZKImpl.java
+++
b/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeerZKImpl.java
@@ -21,8 +21,10 @@ package org.apache.hadoop.hbase.replication;
import java.io.Closeable;
import java.io.IOException;
import java.util.HashMap;
+import java.util.HashSet;
import java.util.List;
import java.util.Map;
+import java.util.Set;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
@@ -172,11 +174,22 @@ public class ReplicationPeerZKImpl extends
ReplicationStateZKBase implements Rep
@Override
public void trackPeerConfigChanges(ReplicationPeerConfigListener listener) {
if (this.peerConfigTracker != null){
- this.peerConfigTracker.setListener(listener);
+ this.peerConfigTracker.addListener(listener);
}
}
@Override
+ public void removeListenerOfPeerConfig(ReplicationPeerConfigListener
listener) {
+if (this.peerConfigTracker != null){
+ this.peerConfigTracker.removeListener(listener);
+}
+ }
+
+ PeerConfigTracker getPeerConfigTracker() {
+return this.peerConfigTracker;
+ }
+
+ @Override
public void abort(String why, Throwable e) {
LOG.fatal("The ReplicationPeer corresponding to peer " + peerConfig
+ " was aborted for the following reason(s):" + why, e);
@@ -275,15 +288,24 @@ public class ReplicationPeerZKImpl extends
ReplicationStateZKBase implements Rep
*/
public class PeerConfigTracker extends ZooKeeperNodeTracker {
-private ReplicationPeerConfigListener listener;
+private Set listeners;
public PeerConfigTracker(String peerConfigNode, ZooKeeperWatcher watcher,
Abortable abortable) {
super(watcher, peerConfigNode, abortable);
+ listeners = new HashSet<>();
+}
+
+public synchronized void addListener(ReplicationPeerConfigListener
listener){
+ listeners.add(listener);
+}
+
+Set getListeners(){
+ return this.listeners;
}
-public synchronized void setListener(ReplicationPeerConfigListener
listener){
- this
hbase git commit: HBASE-20903 backport HBASE-20792 "info:servername and info:sn inconsistent for OPEN region" to branch-2.0 Signed-off-by: zhangduo Signed-off-by: Michael Stack
Repository: hbase
Updated Branches:
refs/heads/branch-2.0 93e8acbe3 -> e0bd4a121
HBASE-20903 backport HBASE-20792 "info:servername and info:sn inconsistent for
OPEN region" to branch-2.0
Signed-off-by: zhangduo
Signed-off-by: Michael Stack
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/e0bd4a12
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/e0bd4a12
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/e0bd4a12
Branch: refs/heads/branch-2.0
Commit: e0bd4a121b2ef451e2b6b34fd95984c5274603c1
Parents: 93e8acb
Author: Allan Yang
Authored: Thu Jul 19 11:18:35 2018 -0700
Committer: Michael Stack
Committed: Thu Jul 19 11:19:29 2018 -0700
--
.../master/assignment/RegionStateStore.java | 6 +-
.../hbase/master/assignment/RegionStates.java | 3 +
.../assignment/TestRegionMoveAndAbandon.java| 129 +++
3 files changed, 135 insertions(+), 3 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/e0bd4a12/hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/RegionStateStore.java
--
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/RegionStateStore.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/RegionStateStore.java
index 9fc2dcf..d85fea7 100644
---
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/RegionStateStore.java
+++
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/RegionStateStore.java
@@ -135,7 +135,7 @@ public class RegionStateStore {
long openSeqNum = regionStateNode.getState() == State.OPEN ?
regionStateNode.getOpenSeqNum() : HConstants.NO_SEQNUM;
updateUserRegionLocation(regionStateNode.getRegionInfo(),
regionStateNode.getState(),
- regionStateNode.getRegionLocation(), regionStateNode.getLastHost(),
openSeqNum,
+ regionStateNode.getRegionLocation(), openSeqNum,
// The regionStateNode may have no procedure in a test scenario;
allow for this.
regionStateNode.getProcedure() != null?
regionStateNode.getProcedure().getProcId():
Procedure.NO_PROC_ID);
@@ -153,7 +153,7 @@ public class RegionStateStore {
}
private void updateUserRegionLocation(final RegionInfo regionInfo, final
State state,
- final ServerName regionLocation, final ServerName lastHost, final long
openSeqNum,
+ final ServerName regionLocation, final long openSeqNum,
final long pid)
throws IOException {
long time = EnvironmentEdgeManager.currentTime();
@@ -169,7 +169,7 @@ public class RegionStateStore {
MetaTableAccessor.addLocation(put, regionLocation, openSeqNum,
replicaId);
info.append(", openSeqNum=").append(openSeqNum);
info.append(", regionLocation=").append(regionLocation);
-} else if (regionLocation != null && !regionLocation.equals(lastHost)) {
+} else if (regionLocation != null) {
// Ideally, if no regionLocation, write null to the hbase:meta but this
will confuse clients
// currently; they want a server to hit. TODO: Make clients wait if no
location.
put.add(CellBuilderFactory.create(CellBuilderType.SHALLOW_COPY)
http://git-wip-us.apache.org/repos/asf/hbase/blob/e0bd4a12/hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/RegionStates.java
--
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/RegionStates.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/RegionStates.java
index af226b7..e4b49af 100644
---
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/RegionStates.java
+++
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/RegionStates.java
@@ -106,6 +106,9 @@ public class RegionStates {
private volatile RegionTransitionProcedure procedure = null;
private volatile ServerName regionLocation = null;
+// notice that, the lastHost will only be updated when a region is
successfully CLOSED through
+// UnassignProcedure, so do not use it for critical condition as the data
maybe stale and unsync
+// with the data in meta.
private volatile ServerName lastHost = null;
/**
* A Region-in-Transition (RIT) moves through states.
http://git-wip-us.apache.org/repos/asf/hbase/blob/e0bd4a12/hbase-server/src/test/java/org/apache/hadoop/hbase/master/assignment/TestRegionMoveAndAbandon.java
--
diff --git
a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/assignment/TestRegionMoveAndAbandon.java
b/hbase-server/src/test/java/
hbase git commit: HBASE-20901 Reducing region replica has no effect
Repository: hbase
Updated Branches:
refs/heads/master c92cda842 -> b4eacdabd
HBASE-20901 Reducing region replica has no effect
Signed-off-by: tedyu
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/b4eacdab
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/b4eacdab
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/b4eacdab
Branch: refs/heads/master
Commit: b4eacdabd6b231748716896fe2cc99868a58e8f4
Parents: c92cda8
Author: Ankit Singhal
Authored: Thu Jul 19 12:37:13 2018 -0700
Committer: tedyu
Committed: Thu Jul 19 13:38:32 2018 -0700
--
.../apache/hadoop/hbase/MetaTableAccessor.java | 27 +
.../master/procedure/EnableTableProcedure.java | 105 +--
.../hadoop/hbase/TestMetaTableAccessor.java | 41 +++-
3 files changed, 118 insertions(+), 55 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/b4eacdab/hbase-client/src/main/java/org/apache/hadoop/hbase/MetaTableAccessor.java
--
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/MetaTableAccessor.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/MetaTableAccessor.java
index 60afaca..77aeb20 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/MetaTableAccessor.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/MetaTableAccessor.java
@@ -847,6 +847,30 @@ public class MetaTableAccessor {
}
/**
+ * Returns the column qualifier for serialized region state
+ * @param replicaId the replicaId of the region
+ * @return a byte[] for state qualifier
+ */
+ @VisibleForTesting
+ public static byte[] getRegionStateColumn(int replicaId) {
+return replicaId == 0 ? HConstants.STATE_QUALIFIER
+: Bytes.toBytes(HConstants.STATE_QUALIFIER_STR +
META_REPLICA_ID_DELIMITER
++ String.format(RegionInfo.REPLICA_ID_FORMAT, replicaId));
+ }
+
+ /**
+ * Returns the column qualifier for serialized region state
+ * @param replicaId the replicaId of the region
+ * @return a byte[] for sn column qualifier
+ */
+ @VisibleForTesting
+ public static byte[] getServerNameColumn(int replicaId) {
+return replicaId == 0 ? HConstants.SERVERNAME_QUALIFIER
+: Bytes.toBytes(HConstants.SERVERNAME_QUALIFIER_STR +
META_REPLICA_ID_DELIMITER
++ String.format(RegionInfo.REPLICA_ID_FORMAT, replicaId));
+ }
+
+ /**
* Returns the column qualifier for server column for replicaId
* @param replicaId the replicaId of the region
* @return a byte[] for server column qualifier
@@ -1406,7 +1430,10 @@ public class MetaTableAccessor {
getSeqNumColumn(i), now);
deleteReplicaLocations.addColumns(getCatalogFamily(),
getStartCodeColumn(i), now);
+deleteReplicaLocations.addColumns(getCatalogFamily(),
getServerNameColumn(i), now);
+deleteReplicaLocations.addColumns(getCatalogFamily(),
getRegionStateColumn(i), now);
}
+
deleteFromMetaTable(connection, deleteReplicaLocations);
}
}
http://git-wip-us.apache.org/repos/asf/hbase/blob/b4eacdab/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/EnableTableProcedure.java
--
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/EnableTableProcedure.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/EnableTableProcedure.java
index c46070c..f2fbb7a 100644
---
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/EnableTableProcedure.java
+++
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/EnableTableProcedure.java
@@ -21,16 +21,12 @@ package org.apache.hadoop.hbase.master.procedure;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
-
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.HConstants;
import org.apache.hadoop.hbase.MetaTableAccessor;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.TableNotDisabledException;
import org.apache.hadoop.hbase.TableNotFoundException;
-import org.apache.yetus.audience.InterfaceAudience;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.RegionInfo;
@@ -42,6 +38,10 @@ import org.apache.hadoop.hbase.client.TableState;
import org.apache.hadoop.hbase.master.MasterCoprocessorHost;
import org.apache.hadoop.hbase.master.TableStateManager;
import org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer;
+import org.apache.yetus.audience.InterfaceAudience;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
hbase git commit: HBASE-20901 Reducing region replica has no effect
Repository: hbase
Updated Branches:
refs/heads/branch-2 35a3c605f -> cf1f63bf9
HBASE-20901 Reducing region replica has no effect
Signed-off-by: tedyu
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/cf1f63bf
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/cf1f63bf
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/cf1f63bf
Branch: refs/heads/branch-2
Commit: cf1f63bf9137305b9cc8f4c6da77f7697ddd713d
Parents: 35a3c60
Author: Ankit Singhal
Authored: Thu Jul 19 12:37:13 2018 -0700
Committer: tedyu
Committed: Thu Jul 19 13:39:44 2018 -0700
--
.../apache/hadoop/hbase/MetaTableAccessor.java | 27 +
.../master/procedure/EnableTableProcedure.java | 105 +--
.../hadoop/hbase/TestMetaTableAccessor.java | 41 +++-
3 files changed, 118 insertions(+), 55 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/cf1f63bf/hbase-client/src/main/java/org/apache/hadoop/hbase/MetaTableAccessor.java
--
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/MetaTableAccessor.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/MetaTableAccessor.java
index 60afaca..77aeb20 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/MetaTableAccessor.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/MetaTableAccessor.java
@@ -847,6 +847,30 @@ public class MetaTableAccessor {
}
/**
+ * Returns the column qualifier for serialized region state
+ * @param replicaId the replicaId of the region
+ * @return a byte[] for state qualifier
+ */
+ @VisibleForTesting
+ public static byte[] getRegionStateColumn(int replicaId) {
+return replicaId == 0 ? HConstants.STATE_QUALIFIER
+: Bytes.toBytes(HConstants.STATE_QUALIFIER_STR +
META_REPLICA_ID_DELIMITER
++ String.format(RegionInfo.REPLICA_ID_FORMAT, replicaId));
+ }
+
+ /**
+ * Returns the column qualifier for serialized region state
+ * @param replicaId the replicaId of the region
+ * @return a byte[] for sn column qualifier
+ */
+ @VisibleForTesting
+ public static byte[] getServerNameColumn(int replicaId) {
+return replicaId == 0 ? HConstants.SERVERNAME_QUALIFIER
+: Bytes.toBytes(HConstants.SERVERNAME_QUALIFIER_STR +
META_REPLICA_ID_DELIMITER
++ String.format(RegionInfo.REPLICA_ID_FORMAT, replicaId));
+ }
+
+ /**
* Returns the column qualifier for server column for replicaId
* @param replicaId the replicaId of the region
* @return a byte[] for server column qualifier
@@ -1406,7 +1430,10 @@ public class MetaTableAccessor {
getSeqNumColumn(i), now);
deleteReplicaLocations.addColumns(getCatalogFamily(),
getStartCodeColumn(i), now);
+deleteReplicaLocations.addColumns(getCatalogFamily(),
getServerNameColumn(i), now);
+deleteReplicaLocations.addColumns(getCatalogFamily(),
getRegionStateColumn(i), now);
}
+
deleteFromMetaTable(connection, deleteReplicaLocations);
}
}
http://git-wip-us.apache.org/repos/asf/hbase/blob/cf1f63bf/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/EnableTableProcedure.java
--
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/EnableTableProcedure.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/EnableTableProcedure.java
index c46070c..f2fbb7a 100644
---
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/EnableTableProcedure.java
+++
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/EnableTableProcedure.java
@@ -21,16 +21,12 @@ package org.apache.hadoop.hbase.master.procedure;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
-
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.HConstants;
import org.apache.hadoop.hbase.MetaTableAccessor;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.TableNotDisabledException;
import org.apache.hadoop.hbase.TableNotFoundException;
-import org.apache.yetus.audience.InterfaceAudience;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.RegionInfo;
@@ -42,6 +38,10 @@ import org.apache.hadoop.hbase.client.TableState;
import org.apache.hadoop.hbase.master.MasterCoprocessorHost;
import org.apache.hadoop.hbase.master.TableStateManager;
import org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer;
+import org.apache.yetus.audience.InterfaceAudience;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
[2/3] hbase git commit: HBASE-20672 New metrics ReadRequestRate and WriteRequestRate
HBASE-20672 New metrics ReadRequestRate and WriteRequestRate
Signed-off-by: Andrew Purtell
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/e5618a66
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/e5618a66
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/e5618a66
Branch: refs/heads/branch-1
Commit: e5618a6674163a5fddd51064c22e67a32fd4bee5
Parents: 15ed2e8
Author: Ankit
Authored: Thu Jun 7 15:03:03 2018 -0700
Committer: Andrew Purtell
Committed: Thu Jul 19 15:36:01 2018 -0700
--
.../regionserver/MetricsRegionServerSource.java | 6
.../MetricsRegionServerWrapper.java | 10 +++
.../MetricsRegionServerSourceImpl.java | 4 +++
.../MetricsRegionServerWrapperImpl.java | 29
.../MetricsRegionServerWrapperStub.java | 10 +++
5 files changed, 59 insertions(+)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/e5618a66/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSource.java
--
diff --git
a/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSource.java
b/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSource.java
index b72deb8..affd267 100644
---
a/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSource.java
+++
b/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSource.java
@@ -253,6 +253,12 @@ public interface MetricsRegionServerSource extends
BaseSource, JvmPauseMonitorSo
String WRITE_REQUEST_COUNT = "writeRequestCount";
String WRITE_REQUEST_COUNT_DESC =
"Number of mutation requests this region server has answered.";
+ String READ_REQUEST_RATE = "readRequestRate";
+ String READ_REQUEST_RATE_DESC =
+ "Rate of answering the read requests by this region server per second.";
+ String WRITE_REQUEST_RATE = "writeRequestRate";
+ String WRITE_REQUEST_RATE_DESC =
+ "Rate of answering the mutation requests by this region server per
second.";
String CHECK_MUTATE_FAILED_COUNT = "checkMutateFailedCount";
String CHECK_MUTATE_FAILED_COUNT_DESC =
"Number of Check and Mutate calls that failed the checks.";
http://git-wip-us.apache.org/repos/asf/hbase/blob/e5618a66/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerWrapper.java
--
diff --git
a/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerWrapper.java
b/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerWrapper.java
index 3344dce..5cbdc64 100644
---
a/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerWrapper.java
+++
b/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerWrapper.java
@@ -133,6 +133,16 @@ public interface MetricsRegionServerWrapper {
long getWriteRequestsCount();
/**
+ * Get the rate of read requests per second to regions hosted on this region
server.
+ */
+ double getReadRequestsRate();
+
+ /**
+ * Get the rate of write requests per second to regions hosted on this
region server.
+ */
+ double getWriteRequestsRate();
+
+ /**
* Get the number of CAS operations that failed.
*/
long getCheckAndMutateChecksFailed();
http://git-wip-us.apache.org/repos/asf/hbase/blob/e5618a66/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSourceImpl.java
--
diff --git
a/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSourceImpl.java
b/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSourceImpl.java
index 208188e..8833026 100644
---
a/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSourceImpl.java
+++
b/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSourceImpl.java
@@ -352,6 +352,10 @@ public class MetricsRegionServerSourceImpl
.addGauge(Interns.info(RS_START_TIME_NAME, RS_START_TIME_DESC),
rsWrap.getStartCode())
.addGauge(Interns.info(AVERAGE_REGION_SIZE,
AVERAGE_REGION_SIZE_DESC), rsWrap.getAverageRegionSize())
+ .addGauge(Interns.info(READ_REQUEST_RATE, READ_REQUEST_RATE_DESC),
+ rsWrap.getReadRequestsRate())
+ .addGauge(Interns.info(WRITE_REQUEST_RATE, WRITE_REQUEST_RATE_DESC),
+ rsWrap.getWriteRequests
[3/3] hbase git commit: HBASE-20672 New metrics ReadRequestRate and WriteRequestRate
HBASE-20672 New metrics ReadRequestRate and WriteRequestRate
Signed-off-by: Andrew Purtell
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/37e5f5fb
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/37e5f5fb
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/37e5f5fb
Branch: refs/heads/branch-2
Commit: 37e5f5fb5fd2a8b95c4fd269e4403db81afea161
Parents: cf1f63b
Author: Ankit
Authored: Thu Jun 7 15:03:03 2018 -0700
Committer: Andrew Purtell
Committed: Thu Jul 19 15:41:53 2018 -0700
--
.../regionserver/MetricsRegionServerSource.java | 6
.../MetricsRegionServerWrapper.java | 10 +++
.../MetricsRegionServerSourceImpl.java | 6 +++-
.../MetricsRegionServerWrapperImpl.java | 29
.../MetricsRegionServerWrapperStub.java | 10 +++
5 files changed, 60 insertions(+), 1 deletion(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/37e5f5fb/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSource.java
--
diff --git
a/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSource.java
b/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSource.java
index 1a1535d..9c0a7b4 100644
---
a/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSource.java
+++
b/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSource.java
@@ -256,12 +256,18 @@ public interface MetricsRegionServerSource extends
BaseSource, JvmPauseMonitorSo
String READ_REQUEST_COUNT = "readRequestCount";
String READ_REQUEST_COUNT_DESC =
"Number of read requests with non-empty Results that this RegionServer
has answered.";
+ String READ_REQUEST_RATE_PER_SECOND = "readRequestRatePerSecond";
+ String READ_REQUEST_RATE_DESC =
+ "Rate of answering the read requests by this region server per second.";
String FILTERED_READ_REQUEST_COUNT = "filteredReadRequestCount";
String FILTERED_READ_REQUEST_COUNT_DESC =
"Number of filtered read requests this RegionServer has answered.";
String WRITE_REQUEST_COUNT = "writeRequestCount";
String WRITE_REQUEST_COUNT_DESC =
"Number of mutation requests this RegionServer has answered.";
+ String WRITE_REQUEST_RATE_PER_SECOND = "writeRequestRatePerSecond";
+ String WRITE_REQUEST_RATE_DESC =
+ "Rate of answering the mutation requests by this region server per
second.";
String CHECK_MUTATE_FAILED_COUNT = "checkMutateFailedCount";
String CHECK_MUTATE_FAILED_COUNT_DESC =
"Number of Check and Mutate calls that failed the checks.";
http://git-wip-us.apache.org/repos/asf/hbase/blob/37e5f5fb/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerWrapper.java
--
diff --git
a/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerWrapper.java
b/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerWrapper.java
index 83a8339..13a5d84 100644
---
a/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerWrapper.java
+++
b/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerWrapper.java
@@ -136,6 +136,11 @@ public interface MetricsRegionServerWrapper {
long getReadRequestsCount();
/**
+ * Get the rate of read requests per second to regions hosted on this region
server.
+ */
+ double getReadRequestsRatePerSecond();
+
+ /**
* Get the number of filtered read requests to regions hosted on this region
server.
*/
long getFilteredReadRequestsCount();
@@ -146,6 +151,11 @@ public interface MetricsRegionServerWrapper {
long getWriteRequestsCount();
/**
+ * Get the rate of write requests per second to regions hosted on this
region server.
+ */
+ double getWriteRequestsRatePerSecond();
+
+ /**
* Get the number of CAS operations that failed.
*/
long getCheckAndMutateChecksFailed();
http://git-wip-us.apache.org/repos/asf/hbase/blob/37e5f5fb/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSourceImpl.java
--
diff --git
a/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSourceImpl.java
b/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSourceImpl.java
index 94b8389..88d9e06 100644
---
a/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/regionse
[1/3] hbase git commit: HBASE-20672 New metrics ReadRequestRate and WriteRequestRate
Repository: hbase
Updated Branches:
refs/heads/branch-1 15ed2e86e -> e5618a667
refs/heads/branch-2 cf1f63bf9 -> 37e5f5fb5
refs/heads/master b4eacdabd -> e66a6603e
HBASE-20672 New metrics ReadRequestRate and WriteRequestRate
Signed-off-by: Andrew Purtell
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/e66a6603
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/e66a6603
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/e66a6603
Branch: refs/heads/master
Commit: e66a6603e36ecd67237ca16acd5e2de03f0d372d
Parents: b4eacda
Author: Ankit
Authored: Thu Jun 7 15:03:03 2018 -0700
Committer: Andrew Purtell
Committed: Thu Jul 19 15:33:09 2018 -0700
--
.../regionserver/MetricsRegionServerSource.java | 6
.../MetricsRegionServerWrapper.java | 10 +++
.../MetricsRegionServerSourceImpl.java | 6 +++-
.../MetricsRegionServerWrapperImpl.java | 29
.../MetricsRegionServerWrapperStub.java | 10 +++
5 files changed, 60 insertions(+), 1 deletion(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/e66a6603/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSource.java
--
diff --git
a/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSource.java
b/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSource.java
index 2ae26e1..77367e7 100644
---
a/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSource.java
+++
b/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSource.java
@@ -256,6 +256,9 @@ public interface MetricsRegionServerSource extends
BaseSource, JvmPauseMonitorSo
String READ_REQUEST_COUNT = "readRequestCount";
String READ_REQUEST_COUNT_DESC =
"Number of read requests with non-empty Results that this RegionServer
has answered.";
+ String READ_REQUEST_RATE_PER_SECOND = "readRequestRatePerSecond";
+ String READ_REQUEST_RATE_DESC =
+ "Rate of answering the read requests by this region server per second.";
String CP_REQUEST_COUNT = "cpRequestCount";
String CP_REQUEST_COUNT_DESC =
"Number of coprocessor service requests this region server has
answered.";
@@ -265,6 +268,9 @@ public interface MetricsRegionServerSource extends
BaseSource, JvmPauseMonitorSo
String WRITE_REQUEST_COUNT = "writeRequestCount";
String WRITE_REQUEST_COUNT_DESC =
"Number of mutation requests this RegionServer has answered.";
+ String WRITE_REQUEST_RATE_PER_SECOND = "writeRequestRatePerSecond";
+ String WRITE_REQUEST_RATE_DESC =
+ "Rate of answering the mutation requests by this region server per
second.";
String CHECK_MUTATE_FAILED_COUNT = "checkMutateFailedCount";
String CHECK_MUTATE_FAILED_COUNT_DESC =
"Number of Check and Mutate calls that failed the checks.";
http://git-wip-us.apache.org/repos/asf/hbase/blob/e66a6603/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerWrapper.java
--
diff --git
a/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerWrapper.java
b/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerWrapper.java
index 02c78c7..b3a8dac 100644
---
a/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerWrapper.java
+++
b/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerWrapper.java
@@ -141,6 +141,11 @@ public interface MetricsRegionServerWrapper {
long getCpRequestsCount();
/**
+ * Get the rate of read requests per second to regions hosted on this region
server.
+ */
+ double getReadRequestsRatePerSecond();
+
+ /**
* Get the number of filtered read requests to regions hosted on this region
server.
*/
long getFilteredReadRequestsCount();
@@ -151,6 +156,11 @@ public interface MetricsRegionServerWrapper {
long getWriteRequestsCount();
/**
+ * Get the rate of write requests per second to regions hosted on this
region server.
+ */
+ double getWriteRequestsRatePerSecond();
+
+ /**
* Get the number of CAS operations that failed.
*/
long getCheckAndMutateChecksFailed();
http://git-wip-us.apache.org/repos/asf/hbase/blob/e66a6603/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSourceImpl.java
--
diff --git
a/hbase-hadoop2-compat/src/main/java/org/apache/hadoop/hbase/regionserver/Metri
hbase git commit: Update version on branch-1.4 to 1.4.6-SNAPSHOT
Repository: hbase Updated Branches: refs/heads/branch-1.4 e142d0560 -> 0da62ac08 Update version on branch-1.4 to 1.4.6-SNAPSHOT Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/0da62ac0 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/0da62ac0 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/0da62ac0 Branch: refs/heads/branch-1.4 Commit: 0da62ac08c5d0edfcf5763a3cd0eb4fd83a02aac Parents: e142d05 Author: Andrew Purtell Authored: Thu Jul 19 16:11:05 2018 -0700 Committer: Andrew Purtell Committed: Thu Jul 19 16:11:05 2018 -0700 -- hbase-annotations/pom.xml| 2 +- hbase-archetypes/hbase-archetype-builder/pom.xml | 2 +- hbase-archetypes/hbase-client-project/pom.xml| 2 +- hbase-archetypes/hbase-shaded-client-project/pom.xml | 2 +- hbase-archetypes/pom.xml | 2 +- hbase-assembly/pom.xml | 2 +- hbase-checkstyle/pom.xml | 4 ++-- hbase-client/pom.xml | 2 +- hbase-common/pom.xml | 2 +- hbase-error-prone/pom.xml| 4 ++-- hbase-examples/pom.xml | 2 +- hbase-external-blockcache/pom.xml| 2 +- hbase-hadoop-compat/pom.xml | 2 +- hbase-hadoop2-compat/pom.xml | 2 +- hbase-it/pom.xml | 2 +- hbase-metrics-api/pom.xml| 2 +- hbase-metrics/pom.xml| 2 +- hbase-prefix-tree/pom.xml| 2 +- hbase-procedure/pom.xml | 2 +- hbase-protocol/pom.xml | 2 +- hbase-resource-bundle/pom.xml| 2 +- hbase-rest/pom.xml | 2 +- hbase-rsgroup/pom.xml| 2 +- hbase-server/pom.xml | 2 +- hbase-shaded/hbase-shaded-check-invariants/pom.xml | 2 +- hbase-shaded/hbase-shaded-client/pom.xml | 2 +- hbase-shaded/hbase-shaded-server/pom.xml | 2 +- hbase-shaded/pom.xml | 2 +- hbase-shell/pom.xml | 2 +- hbase-testing-util/pom.xml | 2 +- hbase-thrift/pom.xml | 2 +- pom.xml | 2 +- 32 files changed, 34 insertions(+), 34 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/0da62ac0/hbase-annotations/pom.xml -- diff --git a/hbase-annotations/pom.xml b/hbase-annotations/pom.xml index c0cdbdc..941c2b4 100644 --- a/hbase-annotations/pom.xml +++ b/hbase-annotations/pom.xml @@ -23,7 +23,7 @@ hbase org.apache.hbase -1.4.5-SNAPSHOT +1.4.6-SNAPSHOT .. http://git-wip-us.apache.org/repos/asf/hbase/blob/0da62ac0/hbase-archetypes/hbase-archetype-builder/pom.xml -- diff --git a/hbase-archetypes/hbase-archetype-builder/pom.xml b/hbase-archetypes/hbase-archetype-builder/pom.xml index 0b5e151..2d44ce2 100644 --- a/hbase-archetypes/hbase-archetype-builder/pom.xml +++ b/hbase-archetypes/hbase-archetype-builder/pom.xml @@ -25,7 +25,7 @@ hbase-archetypes org.apache.hbase -1.4.5-SNAPSHOT +1.4.6-SNAPSHOT .. http://git-wip-us.apache.org/repos/asf/hbase/blob/0da62ac0/hbase-archetypes/hbase-client-project/pom.xml -- diff --git a/hbase-archetypes/hbase-client-project/pom.xml b/hbase-archetypes/hbase-client-project/pom.xml index fe5330a..1add84d 100644 --- a/hbase-archetypes/hbase-client-project/pom.xml +++ b/hbase-archetypes/hbase-client-project/pom.xml @@ -26,7 +26,7 @@ hbase-archetypes org.apache.hbase -1.4.5-SNAPSHOT +1.4.6-SNAPSHOT .. hbase-client-project http://git-wip-us.apache.org/repos/asf/hbase/blob/0da62ac0/hbase-archetypes/hbase-shaded-client-project/pom.xml -- diff --git a/hbase-archetypes/hbase-shaded-client-project/pom.xml b/hbase-archetypes/hbase-shaded-client-project/pom.xml index 059f69c..19dc0d5 100644 --- a/hbase-archetypes/hbase-shaded-client-project/pom.xml +++ b/hbase-archetypes/hbase-shaded-client-project/pom.xml @@ -26,7 +26,7 @@ hbase-archetypes org.apache.hbase -1.4.5-SNAPSHOT +1.4.6-SNAPSHOT .. hbase-shaded-client-project http://git-wip-us.apache.org/repos/asf/hbase/blob/0da62ac0/hbase-archetypes/p
[25/51] [partial] hbase-site git commit: Published site at e66a6603e36ecd67237ca16acd5e2de03f0d372d.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5427a45e/apidocs/org/apache/hadoop/hbase/MasterNotRunningException.html -- diff --git a/apidocs/org/apache/hadoop/hbase/MasterNotRunningException.html b/apidocs/org/apache/hadoop/hbase/MasterNotRunningException.html index 23a0240..f6b49a7 100644 --- a/apidocs/org/apache/hadoop/hbase/MasterNotRunningException.html +++ b/apidocs/org/apache/hadoop/hbase/MasterNotRunningException.html @@ -1,6 +1,6 @@ http://www.w3.org/TR/html4/loose.dtd";> - + @@ -20,38 +20,38 @@ //--> -JavaScript is disabled on your browser. +æ¨çæµè§å¨å·²ç¦ç¨ JavaScriptã -Skip navigation links +è·³è¿å¯¼èªé¾æ¥ - -Overview -Package -Class -Use -Tree -Deprecated -Index -Help + +æ¦è§ +ç¨åºå +ç±» +ä½¿ç¨ +æ +å·²è¿æ¶ +ç´¢å¼ +å¸®å© -Prev Class -Next Class +ä¸ä¸ä¸ªç±» +ä¸ä¸ä¸ªç±» -Frames -No Frames +æ¡æ¶ +æ æ¡æ¶ -All Classes +ææç±»org.apache.hadoop.hbase-Class MasterNotRunningException
+ç±» MasterNotRunningException
-
- https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">java.lang.Object
+- https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="java.langä¸çç±»ææ¥å£">java.lang.Object
-
- https://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true"; title="class or interface in java.lang">java.lang.Throwable
+- https://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true"; title="java.langä¸çç±»ææ¥å£">java.lang.Throwable
-
- https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true"; title="class or interface in java.lang">java.lang.Exception
+- https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true"; title="java.langä¸çç±»ææ¥å£">java.lang.Exception
-
- https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">java.io.IOException
+- https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="java.ioä¸çç±»ææ¥å£">java.io.IOException
-
- org.apache.hadoop.hbase.HBaseIOException
+- org.apache.hadoop.hbase.HBaseIOException
[19/51] [partial] hbase-site git commit: Published site at e66a6603e36ecd67237ca16acd5e2de03f0d372d.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5427a45e/apidocs/org/apache/hadoop/hbase/RetryImmediatelyException.html -- diff --git a/apidocs/org/apache/hadoop/hbase/RetryImmediatelyException.html b/apidocs/org/apache/hadoop/hbase/RetryImmediatelyException.html index 36052a7..08c03f4 100644 --- a/apidocs/org/apache/hadoop/hbase/RetryImmediatelyException.html +++ b/apidocs/org/apache/hadoop/hbase/RetryImmediatelyException.html @@ -1,6 +1,6 @@ http://www.w3.org/TR/html4/loose.dtd";> - + @@ -20,38 +20,38 @@ //--> -JavaScript is disabled on your browser. +æ¨çæµè§å¨å·²ç¦ç¨ JavaScriptã -Skip navigation links +è·³è¿å¯¼èªé¾æ¥ - -Overview -Package -Class -Use -Tree -Deprecated -Index -Help + +æ¦è§ +ç¨åºå +ç±» +ä½¿ç¨ +æ +å·²è¿æ¶ +ç´¢å¼ +å¸®å© -Prev Class -Next Class +ä¸ä¸ä¸ªç±» +ä¸ä¸ä¸ªç±» -Frames -No Frames +æ¡æ¶ +æ æ¡æ¶ -All Classes +ææç±»org.apache.hadoop.hbase-Class RetryImmediatelyException
+ç±» RetryImmediatelyException
-
- https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">java.lang.Object
+- https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="java.langä¸çç±»ææ¥å£">java.lang.Object
-
- https://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true"; title="class or interface in java.lang">java.lang.Throwable
+- https://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true"; title="java.langä¸çç±»ææ¥å£">java.lang.Throwable
-
- https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true"; title="class or interface in java.lang">java.lang.Exception
+- https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true"; title="java.langä¸çç±»ææ¥å£">java.lang.Exception
-
- https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">java.io.IOException
+- https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="java.ioä¸çç±»ææ¥å£">java.io.IOException
- org.apache.hadoop.hbase.RetryImmediatelyException
@@ -117,21 +117,21 @@
-
- All Implemented Interfaces:
-- https://docs.oracle.com/jav
[12/51] [partial] hbase-site git commit: Published site at e66a6603e36ecd67237ca16acd5e2de03f0d372d.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5427a45e/apidocs/org/apache/hadoop/hbase/TableNotDisabledException.html -- diff --git a/apidocs/org/apache/hadoop/hbase/TableNotDisabledException.html b/apidocs/org/apache/hadoop/hbase/TableNotDisabledException.html index 4c5a7f0..0a51c6a 100644 --- a/apidocs/org/apache/hadoop/hbase/TableNotDisabledException.html +++ b/apidocs/org/apache/hadoop/hbase/TableNotDisabledException.html @@ -1,6 +1,6 @@ http://www.w3.org/TR/html4/loose.dtd";> - + @@ -20,38 +20,38 @@ //--> -JavaScript is disabled on your browser. +æ¨çæµè§å¨å·²ç¦ç¨ JavaScriptã -Skip navigation links +è·³è¿å¯¼èªé¾æ¥ - -Overview -Package -Class -Use -Tree -Deprecated -Index -Help + +æ¦è§ +ç¨åºå +ç±» +ä½¿ç¨ +æ +å·²è¿æ¶ +ç´¢å¼ +å¸®å© -Prev Class -Next Class +ä¸ä¸ä¸ªç±» +ä¸ä¸ä¸ªç±» -Frames -No Frames +æ¡æ¶ +æ æ¡æ¶ -All Classes +ææç±»org.apache.hadoop.hbase-Class TableNotDisabledException
+ç±» TableNotDisabledException
-
- https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">java.lang.Object
+- https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="java.langä¸çç±»ææ¥å£">java.lang.Object
-
- https://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true"; title="class or interface in java.lang">java.lang.Throwable
+- https://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true"; title="java.langä¸çç±»ææ¥å£">java.lang.Throwable
-
- https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true"; title="class or interface in java.lang">java.lang.Exception
+- https://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true"; title="java.langä¸çç±»ææ¥å£">java.lang.Exception
-
- https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">java.io.IOException
+- https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="java.ioä¸çç±»ææ¥å£">java.io.IOException
-
- org.apache.hadoop.hbase.HBaseIOException
+- org.apache.hadoop.hbase.HBaseIOException
[32/51] [partial] hbase-site git commit: Published site at e66a6603e36ecd67237ca16acd5e2de03f0d372d.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5427a45e/apidocs/org/apache/hadoop/hbase/HColumnDescriptor.html -- diff --git a/apidocs/org/apache/hadoop/hbase/HColumnDescriptor.html b/apidocs/org/apache/hadoop/hbase/HColumnDescriptor.html index b7f6e3e..9f13b1b 100644 --- a/apidocs/org/apache/hadoop/hbase/HColumnDescriptor.html +++ b/apidocs/org/apache/hadoop/hbase/HColumnDescriptor.html @@ -1,6 +1,6 @@ http://www.w3.org/TR/html4/loose.dtd";> - + @@ -19,45 +19,45 @@ } //--> var methods = {"i0":42,"i1":42,"i2":42,"i3":42,"i4":42,"i5":42,"i6":42,"i7":42,"i8":42,"i9":42,"i10":42,"i11":41,"i12":42,"i13":42,"i14":42,"i15":42,"i16":42,"i17":42,"i18":42,"i19":42,"i20":42,"i21":42,"i22":42,"i23":42,"i24":42,"i25":42,"i26":42,"i27":41,"i28":42,"i29":42,"i30":42,"i31":42,"i32":42,"i33":42,"i34":42,"i35":42,"i36":42,"i37":42,"i38":42,"i39":42,"i40":41,"i41":42,"i42":42,"i43":42,"i44":41,"i45":42,"i46":42,"i47":42,"i48":42,"i49":42,"i50":42,"i51":42,"i52":42,"i53":42,"i54":42,"i55":42,"i56":42,"i57":42,"i58":42,"i59":42,"i60":42,"i61":42,"i62":42,"i63":42,"i64":42,"i65":42,"i66":42,"i67":42,"i68":42,"i69":42,"i70":42,"i71":42,"i72":42,"i73":42,"i74":42,"i75":42,"i76":42,"i77":42,"i78":42,"i79":42,"i80":42,"i81":42,"i82":42}; -var tabs = {65535:["t0","All Methods"],1:["t1","Static Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"],32:["t6","Deprecated Methods"]}; +var tabs = {65535:["t0","æææ¹æ³"],1:["t1","éææ¹æ³"],2:["t2","å®ä¾æ¹æ³"],8:["t4","å ·ä½æ¹æ³"],32:["t6","å·²è¿æ¶çæ¹æ³"]}; var altColor = "altColor"; var rowColor = "rowColor"; var tableTab = "tableTab"; var activeTableTab = "activeTableTab"; -JavaScript is disabled on your browser. +æ¨çæµè§å¨å·²ç¦ç¨ JavaScriptã -Skip navigation links +è·³è¿å¯¼èªé¾æ¥ - -Overview -Package -Class -Use -Tree -Deprecated -Index -Help + +æ¦è§ +ç¨åºå +ç±» +ä½¿ç¨ +æ +å·²è¿æ¶ +ç´¢å¼ +å¸®å© -Prev Class -Next Class +ä¸ä¸ä¸ªç±» +ä¸ä¸ä¸ªç±» -Frames -No Frames +æ¡æ¶ +æ æ¡æ¶ -All Classes +ææç±»
[14/51] [partial] hbase-site git commit: Published site at e66a6603e36ecd67237ca16acd5e2de03f0d372d.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5427a45e/apidocs/org/apache/hadoop/hbase/TableInfoMissingException.html -- diff --git a/apidocs/org/apache/hadoop/hbase/TableInfoMissingException.html b/apidocs/org/apache/hadoop/hbase/TableInfoMissingException.html index 31b337d..91c0977 100644 --- a/apidocs/org/apache/hadoop/hbase/TableInfoMissingException.html +++ b/apidocs/org/apache/hadoop/hbase/TableInfoMissingException.html @@ -1,6 +1,6 @@ http://www.w3.org/TR/html4/loose.dtd";> - + @@ -20,38 +20,38 @@ //--> -JavaScript is disabled on your browser. +æ¨çæµè§å¨å·²ç¦ç¨ JavaScriptã -Skip navigation links +è·³è¿å¯¼èªé¾æ¥ - -Overview -Package -Class -Use -Tree -Deprecated -Index -Help + +æ¦è§ +ç¨åºå +ç±» +ä½¿ç¨ +æ +å·²è¿æ¶ +ç´¢å¼ +å¸®å© -Prev Class -Next Class +ä¸ä¸ä¸ªç±» +ä¸ä¸ä¸ªç±» -Frames -No Frames +æ¡æ¶ +æ æ¡æ¶ -All Classes +ææç±»
[49/51] [partial] hbase-site git commit: Published site at e66a6603e36ecd67237ca16acd5e2de03f0d372d.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5427a45e/apache_hbase_reference_guide.pdf -- diff --git a/apache_hbase_reference_guide.pdf b/apache_hbase_reference_guide.pdf index 58fbfb2..da70f46 100644 --- a/apache_hbase_reference_guide.pdf +++ b/apache_hbase_reference_guide.pdf @@ -5,16 +5,16 @@ /Author (Apache HBase Team) /Creator (Asciidoctor PDF 1.5.0.alpha.15, based on Prawn 2.2.2) /Producer (Apache HBase Team) -/ModDate (D:20180714151517+00'00') -/CreationDate (D:20180714153113+00'00') +/ModDate (D:20180720082544-06'00') +/CreationDate (D:20180720092821-06'00') >> endobj 2 0 obj << /Type /Catalog /Pages 3 0 R /Names 28 0 R -/Outlines 4964 0 R -/PageLabels 5215 0 R +/Outlines 4965 0 R +/PageLabels 5216 0 R /PageMode /UseOutlines /OpenAction [7 0 R /FitH 842.89] /ViewerPreferences << /DisplayDocTitle true @@ -24,7 +24,7 @@ endobj 3 0 obj << /Type /Pages /Count 781 -/Kids [7 0 R 12 0 R 14 0 R 16 0 R 18 0 R 20 0 R 22 0 R 24 0 R 26 0 R 46 0 R 49 0 R 52 0 R 56 0 R 63 0 R 65 0 R 69 0 R 71 0 R 73 0 R 80 0 R 83 0 R 85 0 R 91 0 R 94 0 R 96 0 R 98 0 R 105 0 R 112 0 R 117 0 R 119 0 R 135 0 R 140 0 R 148 0 R 157 0 R 165 0 R 169 0 R 178 0 R 189 0 R 193 0 R 195 0 R 199 0 R 208 0 R 217 0 R 225 0 R 234 0 R 239 0 R 248 0 R 256 0 R 265 0 R 278 0 R 285 0 R 295 0 R 303 0 R 311 0 R 318 0 R 326 0 R 333 0 R 339 0 R 346 0 R 354 0 R 363 0 R 372 0 R 386 0 R 393 0 R 401 0 R 408 0 R 416 0 R 425 0 R 435 0 R 443 0 R 450 0 R 459 0 R 471 0 R 481 0 R 488 0 R 495 0 R 503 0 R 512 0 R 520 0 R 525 0 R 529 0 R 534 0 R 538 0 R 554 0 R 565 0 R 569 0 R 584 0 R 589 0 R 594 0 R 596 0 R 598 0 R 601 0 R 603 0 R 605 0 R 613 0 R 619 0 R 622 0 R 626 0 R 635 0 R 646 0 R 654 0 R 658 0 R 662 0 R 664 0 R 674 0 R 689 0 R 696 0 R 707 0 R 717 0 R 728 0 R 740 0 R 760 0 R 770 0 R 777 0 R 781 0 R 787 0 R 790 0 R 794 0 R 798 0 R 801 0 R 804 0 R 806 0 R 809 0 R 813 0 R 815 0 R 819 0 R 825 0 R 830 0 R 834 0 R 837 0 R 843 0 R 845 0 R 849 0 R 857 0 R 859 0 R 862 0 R 865 0 R 868 0 R 871 0 R 885 0 R 893 0 R 904 0 R 915 0 R 921 0 R 931 0 R 942 0 R 945 0 R 949 0 R 952 0 R 957 0 R 966 0 R 974 0 R 978 0 R 982 0 R 987 0 R 991 0 R 993 0 R 1009 0 R 1020 0 R 1025 0 R 1032 0 R 1035 0 R 1043 0 R 1051 0 R 1056 0 R 1061 0 R 1066 0 R 1068 0 R 1070 0 R 1072 0 R 1082 0 R 1090 0 R 1094 0 R 1101 0 R 1108 0 R 1116 0 R 1120 0 R 1126 0 R 1131 0 R 1139 0 R 1143 0 R 1148 0 R 1150 0 R 1156 0 R 1164 0 R 1170 0 R 1177 0 R 1188 0 R 1192 0 R 1194 0 R 1196 0 R 1200 0 R 1203 0 R 1208 0 R 1211 0 R 1223 0 R 1227 0 R 1233 0 R 1241 0 R 1246 0 R 1250 0 R 1254 0 R 1256 0 R 1259 0 R 1262 0 R 1265 0 R 1269 0 R 1273 0 R 1277 0 R 1282 0 R 1286 0 R 1289 0 R 1291 0 R 1301 0 R 1304 0 R 1312 0 R 1321 0 R 1327 0 R 1331 0 R 1333 0 R 1344 0 R 1347 0 R 1353 0 R 1361 0 R 1364 0 R 1371 0 R 1378 0 R 1381 0 R 1383 0 R 1392 0 R 1394 0 R 1396 0 R 1399 0 R 1401 0 R 1403 0 R 1405 0 R 1407 0 R 1410 0 R 1414 0 R 1419 0 R 1421 0 R 1423 0 R 1425 0 R 1430 0 R 1437 0 R 1443 0 R 1446 0 R 1448 0 R 1451 0 R 1455 0 R 1459 0 R 1462 0 R 1464 0 R 1466 0 R 1469 0 R 1474 0 R 1480 0 R 1488 0 R 1502 0 R 1516 0 R 1519 0 R 1524 0 R 1537 0 R 1542 0 R 1557 0 R 1565 0 R 1569 0 R 1578 0 R 1593 0 R 1607 0 R 1615 0 R 1620 0 R 1631 0 R 1636 0 R 1642 0 R 1648 0 R 1660 0 R 1663 0 R 1672 0 R 1675 0 R 1684 0 R 1690 0 R 1694 0 R 1699 0 R 1711 0 R 1713 0 R 1719 0 R 1725 0 R 1728 0 R 1736 0 R 1744 0 R 1748 0 R 1750 0 R 1752 0 R 1764 0 R 1770 0 R 1779 0 R 1785 0 R 1798 0 R 1804 0 R 1810 0 R 1821 0 R 1827 0 R 1832 0 R 1837 0 R 1840 0 R 1843 0 R 1848 0 R 1853 0 R 1860 0 R 1864 0 R 1869 0 R 1878 0 R 1883 0 R 1888 0 R 1890 0 R 1899 0 R 1906 0 R 1912 0 R 1918 0 R 1922 0 R 1926 0 R 1931 0 R 1936 0 R 1942 0 R 1944 0 R 1946 0 R 1949 0 R 1960 0 R 1963 0 R 1970 0 R 1978 0 R 1983 0 R 1987 0 R 1992 0 R 1994 0 R 1997 0 R 2002 0 R 2005 0 R 2007 0 R 2010 0 R 2013 0 R 2016 0 R 2026 0 R 2031 0 R 2036 0 R 2038 0 R 2046 0 R 2053 0 R 2060 0 R 2066 0 R 2071 0 R 2073 0 R 2082 0 R 2092 0 R 2102 0 R 2108 0 R 2115 0 R 2117 0 R 2122 0 R 2124 0 R 2126 0 R 2130 0 R 2133 0 R 2136 0 R 2141 0 R 2145 0 R 2156 0 R 2159 0 R 2162 0 R 2166 0 R 2170 0 R 2173 0 R 2175 0 R 2180 0 R 2183 0 R 2185 0 R 2190 0 R 2200 0 R 2202 0 R 2204 0 R 2206 0 R 2208 0 R 2211 0 R 2213 0 R 2215 0 R 2218 0 R 2220 0 R 0 R 2226 0 R 2231 0 R 2240 0 R 2242 0 R 2244 0 R 2250 0 R 2252 0 R 2257 0 R 2259 0 R 2261 0 R 2268 0 R 2273 0 R 2277 0 R 2282 0 R 2286 0 R 2288 0 R 2290 0 R 2294 0 R 2297 0 R 2299 0 R 2301 0 R 2305 0 R 2307 0 R 2310 0 R 2312 0 R 2314 0 R 2316 0 R 2323 0 R 2326 0 R 2331 0 R 2333 0 R 2335 0 R 2337 0 R 2339 0 R 2347 0 R 2358 0 R 2372 0 R 2383 0 R 2387 0 R 2392 0 R 2396 0 R 2399 0 R 2404 0 R 2410 0 R 2412 0 R 2415 0 R 2417 0 R 2419 0 R 2421 0 R 2426 0 R 2428 0 R 2441 0 R 2444 0 R 2452 0 R 2458 0 R 2470 0 R 2484 0 R 2497 0 R 2516 0 R 2518 0 R 2520 0 R 2524 0 R 2542 0 R 2548 0 R 2560 0 R 2564 0 R 2568 0 R 2577 0 R 2589 0 R 2594 0 R 2604 0 R 2617 0 R 2636 0
[16/51] [partial] hbase-site git commit: Published site at e66a6603e36ecd67237ca16acd5e2de03f0d372d.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5427a45e/apidocs/org/apache/hadoop/hbase/ServerName.html -- diff --git a/apidocs/org/apache/hadoop/hbase/ServerName.html b/apidocs/org/apache/hadoop/hbase/ServerName.html index 82a2c34..40b8d8e 100644 --- a/apidocs/org/apache/hadoop/hbase/ServerName.html +++ b/apidocs/org/apache/hadoop/hbase/ServerName.html @@ -1,6 +1,6 @@ http://www.w3.org/TR/html4/loose.dtd";> - + @@ -19,45 +19,45 @@ } //--> var methods = {"i0":10,"i1":10,"i2":10,"i3":42,"i4":10,"i5":10,"i6":10,"i7":10,"i8":41,"i9":41,"i10":41,"i11":10,"i12":10,"i13":10,"i14":9,"i15":9,"i16":41,"i17":41,"i18":9,"i19":41,"i20":9,"i21":10,"i22":10,"i23":9,"i24":9,"i25":9}; -var tabs = {65535:["t0","All Methods"],1:["t1","Static Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"],32:["t6","Deprecated Methods"]}; +var tabs = {65535:["t0","æææ¹æ³"],1:["t1","éææ¹æ³"],2:["t2","å®ä¾æ¹æ³"],8:["t4","å ·ä½æ¹æ³"],32:["t6","å·²è¿æ¶çæ¹æ³"]}; var altColor = "altColor"; var rowColor = "rowColor"; var tableTab = "tableTab"; var activeTableTab = "activeTableTab"; -JavaScript is disabled on your browser. +æ¨çæµè§å¨å·²ç¦ç¨ JavaScriptã -Skip navigation links +è·³è¿å¯¼èªé¾æ¥ - -Overview -Package -Class -Use -Tree -Deprecated -Index -Help + +æ¦è§ +ç¨åºå +ç±» +ä½¿ç¨ +æ +å·²è¿æ¶ +ç´¢å¼ +å¸®å© -Prev Class -Next Class +ä¸ä¸ä¸ªç±» +ä¸ä¸ä¸ªç±» -Frames -No Frames +æ¡æ¶ +æ æ¡æ¶ -All Classes +ææç±»
[06/51] [partial] hbase-site git commit: Published site at e66a6603e36ecd67237ca16acd5e2de03f0d372d.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5427a45e/apidocs/org/apache/hadoop/hbase/class-use/CompareOperator.html -- diff --git a/apidocs/org/apache/hadoop/hbase/class-use/CompareOperator.html b/apidocs/org/apache/hadoop/hbase/class-use/CompareOperator.html index 0c69e4c..315944d 100644 --- a/apidocs/org/apache/hadoop/hbase/class-use/CompareOperator.html +++ b/apidocs/org/apache/hadoop/hbase/class-use/CompareOperator.html @@ -1,10 +1,10 @@ http://www.w3.org/TR/html4/loose.dtd";> - + -Uses of Class org.apache.hadoop.hbase.CompareOperator (Apache HBase 3.0.0-SNAPSHOT API) +ç±» org.apache.hadoop.hbase.CompareOperatorçä½¿ç¨ (Apache HBase 3.0.0-SNAPSHOT API) @@ -12,7 +12,7 @@ -JavaScript is disabled on your browser. +æ¨çæµè§å¨å·²ç¦ç¨ JavaScriptã -Skip navigation links +è·³è¿å¯¼èªé¾æ¥ - -Overview -Package -Class -Use -Tree -Deprecated -Index -Help + +æ¦è§ +ç¨åºå +ç±» +ä½¿ç¨ +æ +å·²è¿æ¶ +ç´¢å¼ +å¸®å© -Prev -Next +ä¸ä¸ä¸ª +ä¸ä¸ä¸ª -Frames -No Frames +æ¡æ¶ +æ æ¡æ¶ -All Classes +ææç±»
[05/51] [partial] hbase-site git commit: Published site at e66a6603e36ecd67237ca16acd5e2de03f0d372d.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5427a45e/apidocs/org/apache/hadoop/hbase/class-use/DoNotRetryIOException.html -- diff --git a/apidocs/org/apache/hadoop/hbase/class-use/DoNotRetryIOException.html b/apidocs/org/apache/hadoop/hbase/class-use/DoNotRetryIOException.html index 0a58d3f..a652985 100644 --- a/apidocs/org/apache/hadoop/hbase/class-use/DoNotRetryIOException.html +++ b/apidocs/org/apache/hadoop/hbase/class-use/DoNotRetryIOException.html @@ -1,10 +1,10 @@ http://www.w3.org/TR/html4/loose.dtd";> - + -Uses of Class org.apache.hadoop.hbase.DoNotRetryIOException (Apache HBase 3.0.0-SNAPSHOT API) +ç±» org.apache.hadoop.hbase.DoNotRetryIOExceptionçä½¿ç¨ (Apache HBase 3.0.0-SNAPSHOT API) @@ -12,7 +12,7 @@ -JavaScript is disabled on your browser. +æ¨çæµè§å¨å·²ç¦ç¨ JavaScriptã -Skip navigation links +è·³è¿å¯¼èªé¾æ¥ - -Overview -Package -Class -Use -Tree -Deprecated -Index -Help + +æ¦è§ +ç¨åºå +ç±» +ä½¿ç¨ +æ +å·²è¿æ¶ +ç´¢å¼ +å¸®å© -Prev -Next +ä¸ä¸ä¸ª +ä¸ä¸ä¸ª -Frames -No Frames +æ¡æ¶ +æ æ¡æ¶ -All Classes +ææç±»-Uses of Class
+
org.apache.hadoop.hbase.DoNotRetryIOExceptionç±»ç使ç¨
org.apache.hadoop.hbase.DoNotRetryIOException
- -