Repository: hbase
Updated Branches:
refs/heads/branch-2 add997451 -> cf050de91
HBASE-18522 Add RowMutations support to Batch
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/cf050de9
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/cf050de9
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/cf050de9
Branch: refs/heads/branch-2
Commit: cf050de9172a36b767eb7e4700787b9d6a32a1b9
Parents: add9974
Author: Jerry He
Authored: Mon Aug 14 09:28:49 2017 -0700
Committer: Jerry He
Committed: Mon Aug 14 10:43:10 2017 -0700
--
.../hbase/client/MultiServerCallable.java | 64 +++-
.../org/apache/hadoop/hbase/client/Table.java | 4 +-
.../hbase/shaded/protobuf/RequestConverter.java | 6 +-
.../shaded/protobuf/ResponseConverter.java | 37 ++-
.../hbase/client/TestFromClientSide3.java | 46 ++
.../hadoop/hbase/client/TestMultiParallel.java | 34 ++-
6 files changed, 168 insertions(+), 23 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/cf050de9/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MultiServerCallable.java
--
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MultiServerCallable.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MultiServerCallable.java
index 33c9a0b..7f6052e 100644
---
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MultiServerCallable.java
+++
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MultiServerCallable.java
@@ -19,6 +19,7 @@ package org.apache.hadoop.hbase.client;
import java.io.IOException;
import java.util.ArrayList;
+import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -93,30 +94,64 @@ class MultiServerCallable extends
CancellableRegionServerCallable
RegionAction.Builder regionActionBuilder = RegionAction.newBuilder();
ClientProtos.Action.Builder actionBuilder =
ClientProtos.Action.newBuilder();
MutationProto.Builder mutationBuilder = MutationProto.newBuilder();
-List cells = null;
-// The multi object is a list of Actions by region. Iterate by region.
+
+// Pre-size. Presume at least a KV per Action. There are likely more.
+List cells =
+(this.cellBlock ? new ArrayList(countOfActions) : null);
+
long nonceGroup = multiAction.getNonceGroup();
if (nonceGroup != HConstants.NO_NONCE) {
multiRequestBuilder.setNonceGroup(nonceGroup);
}
+// Index to track RegionAction within the MultiRequest
+int regionActionIndex = -1;
+// Map from a created RegionAction to the original index for a
RowMutations within
+// its original list of actions
+Map rowMutationsIndexMap = new HashMap<>();
+// The multi object is a list of Actions by region. Iterate by region.
for (Map.Entry e:
this.multiAction.actions.entrySet()) {
final byte [] regionName = e.getKey();
final List actions = e.getValue();
regionActionBuilder.clear();
regionActionBuilder.setRegion(RequestConverter.buildRegionSpecifier(
HBaseProtos.RegionSpecifier.RegionSpecifierType.REGION_NAME,
regionName));
- if (this.cellBlock) {
-// Pre-size. Presume at least a KV per Action. There are likely more.
-if (cells == null) cells = new ArrayList<>(countOfActions);
-// Send data in cellblocks. The call to buildNoDataMultiRequest will
skip RowMutations.
-// They have already been handled above. Guess at count of cells
-regionActionBuilder =
RequestConverter.buildNoDataRegionAction(regionName, actions, cells,
- regionActionBuilder, actionBuilder, mutationBuilder);
- } else {
-regionActionBuilder = RequestConverter.buildRegionAction(regionName,
actions,
- regionActionBuilder, actionBuilder, mutationBuilder);
+
+ int rowMutations = 0;
+ for (Action action : actions) {
+Row row = action.getAction();
+// Row Mutations are a set of Puts and/or Deletes all to be applied
atomically
+// on the one row. We do separate RegionAction for each RowMutations.
+// We maintain a map to keep track of this RegionAction and the
original Action index.
+if (row instanceof RowMutations) {
+ RowMutations rms = (RowMutations)row;
+ if (this.cellBlock) {
+// Build a multi request absent its Cell payload. Send data in
cellblocks.
+regionActionBuilder =
RequestConverter.buildNoDataRegionAction(regionName, rms, cells,
+ regionActionBuilder, actionBuilder, mutationBuilder);
+ } else {
+
Repository: hbase
Updated Branches:
refs/heads/master bd4007309 -> 096dac2e8
HBASE-18522 Add RowMutations support to Batch
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/096dac2e
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/096dac2e
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/096dac2e
Branch: refs/heads/master
Commit: 096dac2e83c675f212bad4f91888d8440ba152ca
Parents: bd40073
Author: Jerry He
Authored: Mon Aug 14 10:39:46 2017 -0700
Committer: Jerry He
Committed: Mon Aug 14 10:39:46 2017 -0700
--
.../hbase/client/MultiServerCallable.java | 64 +++-
.../org/apache/hadoop/hbase/client/Table.java | 4 +-
.../hbase/shaded/protobuf/RequestConverter.java | 6 +-
.../shaded/protobuf/ResponseConverter.java | 37 ++-
.../hbase/client/TestFromClientSide3.java | 46 ++
.../hadoop/hbase/client/TestMultiParallel.java | 34 ++-
6 files changed, 168 insertions(+), 23 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/096dac2e/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MultiServerCallable.java
--
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MultiServerCallable.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MultiServerCallable.java
index 33c9a0b..7f6052e 100644
---
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MultiServerCallable.java
+++
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MultiServerCallable.java
@@ -19,6 +19,7 @@ package org.apache.hadoop.hbase.client;
import java.io.IOException;
import java.util.ArrayList;
+import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -93,30 +94,64 @@ class MultiServerCallable extends
CancellableRegionServerCallable
RegionAction.Builder regionActionBuilder = RegionAction.newBuilder();
ClientProtos.Action.Builder actionBuilder =
ClientProtos.Action.newBuilder();
MutationProto.Builder mutationBuilder = MutationProto.newBuilder();
-List cells = null;
-// The multi object is a list of Actions by region. Iterate by region.
+
+// Pre-size. Presume at least a KV per Action. There are likely more.
+List cells =
+(this.cellBlock ? new ArrayList(countOfActions) : null);
+
long nonceGroup = multiAction.getNonceGroup();
if (nonceGroup != HConstants.NO_NONCE) {
multiRequestBuilder.setNonceGroup(nonceGroup);
}
+// Index to track RegionAction within the MultiRequest
+int regionActionIndex = -1;
+// Map from a created RegionAction to the original index for a
RowMutations within
+// its original list of actions
+Map rowMutationsIndexMap = new HashMap<>();
+// The multi object is a list of Actions by region. Iterate by region.
for (Map.Entry e:
this.multiAction.actions.entrySet()) {
final byte [] regionName = e.getKey();
final List actions = e.getValue();
regionActionBuilder.clear();
regionActionBuilder.setRegion(RequestConverter.buildRegionSpecifier(
HBaseProtos.RegionSpecifier.RegionSpecifierType.REGION_NAME,
regionName));
- if (this.cellBlock) {
-// Pre-size. Presume at least a KV per Action. There are likely more.
-if (cells == null) cells = new ArrayList<>(countOfActions);
-// Send data in cellblocks. The call to buildNoDataMultiRequest will
skip RowMutations.
-// They have already been handled above. Guess at count of cells
-regionActionBuilder =
RequestConverter.buildNoDataRegionAction(regionName, actions, cells,
- regionActionBuilder, actionBuilder, mutationBuilder);
- } else {
-regionActionBuilder = RequestConverter.buildRegionAction(regionName,
actions,
- regionActionBuilder, actionBuilder, mutationBuilder);
+
+ int rowMutations = 0;
+ for (Action action : actions) {
+Row row = action.getAction();
+// Row Mutations are a set of Puts and/or Deletes all to be applied
atomically
+// on the one row. We do separate RegionAction for each RowMutations.
+// We maintain a map to keep track of this RegionAction and the
original Action index.
+if (row instanceof RowMutations) {
+ RowMutations rms = (RowMutations)row;
+ if (this.cellBlock) {
+// Build a multi request absent its Cell payload. Send data in
cellblocks.
+regionActionBuilder =
RequestConverter.buildNoDataRegionAction(regionName, rms, cells,
+ regionActionBuilder, actionBuilder, mutationBuilder);
+ } else {
+regionActionBuilder
Repository: hbase
Updated Branches:
refs/heads/branch-1 7bd2795ee -> 9078a034c
HBASE-18522 Add RowMutations support to Batch
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/9078a034
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/9078a034
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/9078a034
Branch: refs/heads/branch-1
Commit: 9078a034c410d53800e656d6a19f810c30fc102f
Parents: 7bd2795
Author: Jerry He
Authored: Sun Aug 13 18:23:49 2017 -0700
Committer: Jerry He
Committed: Mon Aug 14 09:21:53 2017 -0700
--
.../hbase/client/MultiServerCallable.java | 66 +++-
.../org/apache/hadoop/hbase/client/Table.java | 6 +-
.../hadoop/hbase/protobuf/RequestConverter.java | 6 +-
.../hbase/protobuf/ResponseConverter.java | 35 ++-
.../hbase/client/TestFromClientSide3.java | 46 ++
.../hadoop/hbase/client/TestMultiParallel.java | 49 ---
6 files changed, 178 insertions(+), 30 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/9078a034/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MultiServerCallable.java
--
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MultiServerCallable.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MultiServerCallable.java
index 42c63eb..b2ea941 100644
---
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MultiServerCallable.java
+++
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MultiServerCallable.java
@@ -19,6 +19,7 @@ package org.apache.hadoop.hbase.client;
import java.io.IOException;
import java.util.ArrayList;
+import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -97,12 +98,21 @@ class MultiServerCallable extends
PayloadCarryingServerCallable cells = null;
-// The multi object is a list of Actions by region. Iterate by region.
+
+// Pre-size. Presume at least a KV per Action. There are likely more.
+List cells =
+(this.cellBlock ? new ArrayList(countOfActions) : null);
+
long nonceGroup = multiAction.getNonceGroup();
if (nonceGroup != HConstants.NO_NONCE) {
multiRequestBuilder.setNonceGroup(nonceGroup);
}
+// Index to track RegionAction within the MultiRequest
+int regionActionIndex = -1;
+// Map from a created RegionAction for a RowMutations to the original
index within
+// its original list of actions
+Map rowMutationsIndexMap = new HashMap<>();
+// The multi object is a list of Actions by region. Iterate by region.
for (Map.Entry> e:
this.multiAction.actions.entrySet()) {
final byte [] regionName = e.getKey();
final List actions = e.getValue();
@@ -110,19 +120,46 @@ class MultiServerCallable extends
PayloadCarryingServerCallable action : actions) {
+Row row = action.getAction();
+// Row Mutations are a set of Puts and/or Deletes all to be applied
atomically
+// on the one row. We do separate RegionAction for each RowMutations.
+// We maintain a map to keep track of this RegionAction and the
original Action index.
+if (row instanceof RowMutations) {
+ RowMutations rms = (RowMutations)row;
+ if (this.cellBlock) {
+// Build a multi request absent its Cell payload. Send data in
cellblocks.
+regionActionBuilder =
RequestConverter.buildNoDataRegionAction(regionName, rms, cells,
+ regionActionBuilder, actionBuilder, mutationBuilder);
+ } else {
+regionActionBuilder =
RequestConverter.buildRegionAction(regionName, rms);
+ }
+ regionActionBuilder.setAtomic(true);
+ multiRequestBuilder.addRegionAction(regionActionBuilder.build());
+ regionActionIndex++;
+ rowMutationsIndexMap.put(regionActionIndex,
action.getOriginalIndex());
+ rowMutations++;
+
+ regionActionBuilder.clear();
+ regionActionBuilder.setRegion(RequestConverter.buildRegionSpecifier(
+HBaseProtos.RegionSpecifier.RegionSpecifierType.REGION_NAME,
regionName) );
+}
+ }
- if (this.cellBlock) {
-// Presize. Presume at least a KV per Action. There are likely more.
-if (cells == null) cells = new
ArrayList(countOfActions);
-// Send data in cellblocks. The call to buildNoDataMultiRequest will
skip RowMutations.
-// They have already been handled above. Guess at count of cells
-regionActionBuilder =
RequestConverter.buildNoDataRegionAction(regionName, actions, cells,
- regionActionBuilder,
Repository: hbase
Updated Branches:
refs/heads/branch-1.4 043211760 -> c6f57e0f3
HBASE-18522 Add RowMutations support to Batch
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/c6f57e0f
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/c6f57e0f
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/c6f57e0f
Branch: refs/heads/branch-1.4
Commit: c6f57e0f382e9dcef48f05da087d12eb0e47e9ad
Parents: 0432117
Author: Jerry He
Authored: Sun Aug 13 18:23:49 2017 -0700
Committer: Jerry He
Committed: Mon Aug 14 09:18:41 2017 -0700
--
.../hbase/client/MultiServerCallable.java | 66 +++-
.../org/apache/hadoop/hbase/client/Table.java | 6 +-
.../hadoop/hbase/protobuf/RequestConverter.java | 6 +-
.../hbase/protobuf/ResponseConverter.java | 35 ++-
.../hbase/client/TestFromClientSide3.java | 46 ++
.../hadoop/hbase/client/TestMultiParallel.java | 49 ---
6 files changed, 178 insertions(+), 30 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/c6f57e0f/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MultiServerCallable.java
--
diff --git
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MultiServerCallable.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MultiServerCallable.java
index 42c63eb..b2ea941 100644
---
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MultiServerCallable.java
+++
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MultiServerCallable.java
@@ -19,6 +19,7 @@ package org.apache.hadoop.hbase.client;
import java.io.IOException;
import java.util.ArrayList;
+import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -97,12 +98,21 @@ class MultiServerCallable extends
PayloadCarryingServerCallable cells = null;
-// The multi object is a list of Actions by region. Iterate by region.
+
+// Pre-size. Presume at least a KV per Action. There are likely more.
+List cells =
+(this.cellBlock ? new ArrayList(countOfActions) : null);
+
long nonceGroup = multiAction.getNonceGroup();
if (nonceGroup != HConstants.NO_NONCE) {
multiRequestBuilder.setNonceGroup(nonceGroup);
}
+// Index to track RegionAction within the MultiRequest
+int regionActionIndex = -1;
+// Map from a created RegionAction for a RowMutations to the original
index within
+// its original list of actions
+Map rowMutationsIndexMap = new HashMap<>();
+// The multi object is a list of Actions by region. Iterate by region.
for (Map.Entry> e:
this.multiAction.actions.entrySet()) {
final byte [] regionName = e.getKey();
final List actions = e.getValue();
@@ -110,19 +120,46 @@ class MultiServerCallable extends
PayloadCarryingServerCallable action : actions) {
+Row row = action.getAction();
+// Row Mutations are a set of Puts and/or Deletes all to be applied
atomically
+// on the one row. We do separate RegionAction for each RowMutations.
+// We maintain a map to keep track of this RegionAction and the
original Action index.
+if (row instanceof RowMutations) {
+ RowMutations rms = (RowMutations)row;
+ if (this.cellBlock) {
+// Build a multi request absent its Cell payload. Send data in
cellblocks.
+regionActionBuilder =
RequestConverter.buildNoDataRegionAction(regionName, rms, cells,
+ regionActionBuilder, actionBuilder, mutationBuilder);
+ } else {
+regionActionBuilder =
RequestConverter.buildRegionAction(regionName, rms);
+ }
+ regionActionBuilder.setAtomic(true);
+ multiRequestBuilder.addRegionAction(regionActionBuilder.build());
+ regionActionIndex++;
+ rowMutationsIndexMap.put(regionActionIndex,
action.getOriginalIndex());
+ rowMutations++;
+
+ regionActionBuilder.clear();
+ regionActionBuilder.setRegion(RequestConverter.buildRegionSpecifier(
+HBaseProtos.RegionSpecifier.RegionSpecifierType.REGION_NAME,
regionName) );
+}
+ }
- if (this.cellBlock) {
-// Presize. Presume at least a KV per Action. There are likely more.
-if (cells == null) cells = new
ArrayList(countOfActions);
-// Send data in cellblocks. The call to buildNoDataMultiRequest will
skip RowMutations.
-// They have already been handled above. Guess at count of cells
-regionActionBuilder =
RequestConverter.buildNoDataRegionAction(regionName, actions, cells,
- regionActionBuilder,
HBASE-18520 Add jmx value to determine true Master Start time; amendment
This is to determine how long it took in total for the master to start and
finish initializing.
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/04321176
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/04321176
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/04321176
Branch: refs/heads/branch-1.4
Commit: 043211760394f6e5885bbb199f632b7be4fee9cd
Parents: 16223bc
Author: Zach York
Authored: Thu Jun 15 17:10:07 2017 -0700
Committer: Andrew Purtell
Committed: Mon Aug 14 08:43:13 2017 -0700
--
.../java/org/apache/hadoop/hbase/master/MetricsMasterWrapper.java | 3 +++
.../src/main/java/org/apache/hadoop/hbase/master/HMaster.java | 3 ++-
2 files changed, 5 insertions(+), 1 deletion(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/04321176/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterWrapper.java
--
diff --git
a/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterWrapper.java
b/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterWrapper.java
index 812cad9..6938e87 100644
---
a/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterWrapper.java
+++
b/hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/master/MetricsMasterWrapper.java
@@ -125,5 +125,8 @@ public interface MetricsMasterWrapper {
/**
* Get the time in Millis when the master finished initializing/becoming the
active master
*/
+ /**
+ * Get the time in Millis when the master finished initializing/becoming the
active master
+ */
long getMasterInitializationTime();
}
http://git-wip-us.apache.org/repos/asf/hbase/blob/04321176/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
--
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
index 950ea4a..5b1aed6 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
@@ -894,7 +894,8 @@ public class HMaster extends HRegionServer implements
MasterServices, Server {
}
status.markComplete("Initialization successful");
-LOG.info("Master has completed initialization");
+LOG.info(String.format("Master has completed initialization %.3fsec",
+ (System.currentTimeMillis() - masterActiveTime) / 1000.0f));
this.masterFinishedInitializationTime = System.currentTimeMillis();
configurationManager.registerObserver(this.balancer);
Repository: hbase
Updated Branches:
refs/heads/branch-1.4 2523e716f -> 043211760
HBASE-18387: [Thrift] Make principal configurable in DemoClient.java
Added optional (fourth) parameter "server-principal"
The solution is backward compatible, in case not given, uses "hbase" as default
value
If the third parameter is skipped the fourth cannot be set.
Signed-off-by: Josh Elser
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/2d06c1f7
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/2d06c1f7
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/2d06c1f7
Branch: refs/heads/branch-1.4
Commit: 2d06c1f7ba65f5a153adc726cc9c5cd9805bac5d
Parents: 2523e71
Author: Tamas Penzes
Authored: Tue Aug 8 13:45:09 2017 +0200
Committer: Andrew Purtell
Committed: Mon Aug 14 08:41:40 2017 -0700
--
hbase-examples/README.txt| 3 ++-
.../org/apache/hadoop/hbase/thrift/DemoClient.java | 15 ---
2 files changed, 14 insertions(+), 4 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/hbase/blob/2d06c1f7/hbase-examples/README.txt
--
diff --git a/hbase-examples/README.txt b/hbase-examples/README.txt
index 6578bb4..d2ddcc7 100644
--- a/hbase-examples/README.txt
+++ b/hbase-examples/README.txt
@@ -28,7 +28,8 @@ Example code.
2. If HBase server is not secure, or authentication is not enabled for
the Thrift server, execute:
{java -cp hbase-examples-[VERSION].jar:${HBASE_EXAMPLE_CLASSPATH}
org.apache.hadoop.hbase.thrift.DemoClient }
3. If HBase server is secure, and authentication is enabled for the
Thrift server, run kinit at first, then execute:
- {java -cp hbase-examples-[VERSION].jar:${HBASE_EXAMPLE_CLASSPATH}
org.apache.hadoop.hbase.thrift.DemoClient true}
+ {java -cp hbase-examples-[VERSION].jar:${HBASE_EXAMPLE_CLASSPATH}
org.apache.hadoop.hbase.thrift.DemoClient true }
+ should only be specified when the client connects to
a secure cluster. It's default value is "hbase".
4. Here is a lazy example that just pulls in all hbase dependency jars
and that goes against default location on localhost.
It should work with a standalone hbase instance started by doing
./bin/start-hbase.sh:
{java -cp
./hbase-examples/target/hbase-examples-2.0.0-SNAPSHOT.jar:`./bin/hbase
classpath` org.apache.hadoop.hbase.thrift.DemoClient localhost 9090}
http://git-wip-us.apache.org/repos/asf/hbase/blob/2d06c1f7/hbase-examples/src/main/java/org/apache/hadoop/hbase/thrift/DemoClient.java
--
diff --git
a/hbase-examples/src/main/java/org/apache/hadoop/hbase/thrift/DemoClient.java
b/hbase-examples/src/main/java/org/apache/hadoop/hbase/thrift/DemoClient.java
index 64adc93..e5400f3 100644
---
a/hbase-examples/src/main/java/org/apache/hadoop/hbase/thrift/DemoClient.java
+++
b/hbase-examples/src/main/java/org/apache/hadoop/hbase/thrift/DemoClient.java
@@ -60,13 +60,14 @@ public class DemoClient {
CharsetDecoder decoder = null;
private static boolean secure = false;
+private static String serverPrincipal = "hbase";
public static void main(String[] args) throws Exception {
-if (args.length < 2 || args.length > 3) {
+if (args.length < 2 || args.length > 4 || (args.length > 2 &&
!isBoolean(args[2]))) {
System.out.println("Invalid arguments!");
-System.out.println("Usage: DemoClient host port [secure=false]");
+System.out.println("Usage: DemoClient host port [secure=false
[server-principal=hbase] ]");
System.exit(-1);
}
@@ -77,6 +78,10 @@ public class DemoClient {
secure = Boolean.parseBoolean(args[2]);
}
+if (args.length == 4) {
+ serverPrincipal = args[3];
+}
+
final DemoClient client = new DemoClient();
Subject.doAs(getSubject(),
new PrivilegedExceptionAction() {
@@ -88,6 +93,10 @@ public class DemoClient {
});
}
+private static boolean isBoolean(String s){
+ return Boolean.TRUE.toString().equalsIgnoreCase(s) ||
Boolean.FALSE.toString().equalsIgnoreCase(s);
+}
+
DemoClient() {
decoder = Charset.forName("UTF-8").newDecoder();
}
@@ -123,7 +132,7 @@ public class DemoClient {
* The HBase cluster must be secure, allow proxy user.
*/
transport = new TSaslClientTransport("GSSAPI", null,
-"hbase", // Thrift server user name, should be an authorized proxy
user.
+serverPrincipal, // Thrift server user name, should be an
authorized proxy user.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8bae1c8a/devapidocs/org/apache/hadoop/hbase/client/RawAsyncHBaseAdmin.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/client/RawAsyncHBaseAdmin.html
b/devapidocs/org/apache/hadoop/hbase/client/RawAsyncHBaseAdmin.html
index 521ae2d..ce60328 100644
--- a/devapidocs/org/apache/hadoop/hbase/client/RawAsyncHBaseAdmin.html
+++ b/devapidocs/org/apache/hadoop/hbase/client/RawAsyncHBaseAdmin.html
@@ -18,7 +18,7 @@
catch(err) {
}
//-->
-var methods =
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10,"i35":10,"i36":10,"i37":10,"i38":10,"i39":10,"i40":10,"i41":10,"i42":10,"i43":10,"i44":10,"i45":10,"i46":10,"i47":10,"i48":10,"i49":10,"i50":10,"i51":10,"i52":10,"i53":10,"i54":10,"i55":10,"i56":10,"i57":10,"i58":10,"i59":10,"i60":10,"i61":10,"i62":10,"i63":10,"i64":10,"i65":10,"i66":10,"i67":10,"i68":10,"i69":10,"i70":10,"i71":10,"i72":10,"i73":10,"i74":10,"i75":10,"i76":10,"i77":10,"i78":10,"i79":10,"i80":10,"i81":10,"i82":10,"i83":10,"i84":10,"i85":10,"i86":10,"i87":10,"i88":10,"i89":10,"i90":10,"i91":10,"i92":10,"i93":10,"i94":10,"i95":10,"i96":10,"i97":10,"i98":10,"i99":10,"i100":10,"i101":10,"i102":10,"i103":10,"i104":10,"i105":10,"i106":10,"i107":10,"i108":10,"i
109":10,"i110":10,"i111":10,"i112":10,"i113":10,"i114":10,"i115":10,"i116":10,"i117":10,"i118":10,"i119":10,"i120":10,"i121":10,"i122":10,"i123":10,"i124":10,"i125":10,"i126":10,"i127":10,"i128":10,"i129":10,"i130":10,"i131":10,"i132":10,"i133":10,"i134":10,"i135":10,"i136":10,"i137":10,"i138":10};
+var methods =
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10,"i35":10,"i36":10,"i37":10,"i38":10,"i39":10,"i40":10,"i41":10,"i42":10,"i43":10,"i44":10,"i45":10,"i46":10,"i47":10,"i48":10,"i49":10,"i50":10,"i51":10,"i52":10,"i53":10,"i54":10,"i55":10,"i56":10,"i57":10,"i58":10,"i59":10,"i60":10,"i61":10,"i62":10,"i63":10,"i64":10,"i65":10,"i66":10,"i67":10,"i68":10,"i69":10,"i70":10,"i71":10,"i72":10,"i73":10,"i74":10,"i75":10,"i76":10,"i77":10,"i78":10,"i79":10,"i80":10,"i81":10,"i82":10,"i83":10,"i84":10,"i85":10,"i86":10,"i87":10,"i88":10,"i89":10,"i90":10,"i91":10,"i92":10,"i93":10,"i94":10,"i95":10,"i96":10,"i97":10,"i98":10,"i99":10,"i100":10,"i101":10,"i102":10,"i103":10,"i104":10,"i105":10,"i106":10,"i107":10,"i108":10,"i
109":10,"i110":10,"i111":10,"i112":10,"i113":10,"i114":10,"i115":10,"i116":10,"i117":10,"i118":10,"i119":10,"i120":10,"i121":10,"i122":10,"i123":10,"i124":10,"i125":10,"i126":10,"i127":10,"i128":10,"i129":10,"i130":10,"i131":10,"i132":10,"i133":10,"i134":10,"i135":10,"i136":10,"i137":10,"i138":10,"i139":10};
var tabs = {65535:["t0","All Methods"],2:["t2","Instance
Methods"],8:["t4","Concrete Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
@@ -623,151 +623,155 @@ implements getClusterStatus()
+http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true;
title="class or interface in java.util.concurrent">CompletableFutureClusterStatus
+getClusterStatus(ClusterStatus.Optionsoptions)
+
+
http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true;
title="class or interface in java.util.concurrent">CompletableFutureCompactionState
getCompactionState(TableNametableName)
Get the current compaction state of a table.
-
+
http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true;
title="class or interface in java.util.concurrent">CompletableFutureCompactionState
getCompactionStateForRegion(byte[]regionName)
Get the current compaction state of region.
-
+
http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true;
title="class or interface in java.util.concurrent">CompletableFuturehttp://docs.oracle.com/javase/8/docs/api/java/util/Optional.html?is-external=true;
title="class or interface in java.util">Optionalhttp://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true;
title="class or interface in java.lang">Long
getLastMajorCompactionTimestamp(TableNametableName)
Get the timestamp of the last major compaction for the
passed table.
-
+
http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true;
title="class or interface in
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8bae1c8a/devapidocs/org/apache/hadoop/hbase/client/Admin.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/client/Admin.html
b/devapidocs/org/apache/hadoop/hbase/client/Admin.html
index acc88a2..88b7fa7 100644
--- a/devapidocs/org/apache/hadoop/hbase/client/Admin.html
+++ b/devapidocs/org/apache/hadoop/hbase/client/Admin.html
@@ -18,7 +18,7 @@
catch(err) {
}
//-->
-var methods =
{"i0":6,"i1":6,"i2":6,"i3":38,"i4":6,"i5":6,"i6":18,"i7":18,"i8":6,"i9":6,"i10":6,"i11":6,"i12":6,"i13":6,"i14":6,"i15":6,"i16":6,"i17":38,"i18":38,"i19":38,"i20":38,"i21":6,"i22":6,"i23":6,"i24":6,"i25":6,"i26":6,"i27":6,"i28":6,"i29":6,"i30":6,"i31":6,"i32":50,"i33":50,"i34":50,"i35":6,"i36":6,"i37":6,"i38":50,"i39":6,"i40":38,"i41":6,"i42":6,"i43":6,"i44":6,"i45":6,"i46":6,"i47":6,"i48":6,"i49":6,"i50":6,"i51":38,"i52":38,"i53":6,"i54":6,"i55":18,"i56":6,"i57":6,"i58":6,"i59":38,"i60":38,"i61":6,"i62":6,"i63":18,"i64":6,"i65":6,"i66":6,"i67":38,"i68":38,"i69":6,"i70":6,"i71":6,"i72":6,"i73":38,"i74":6,"i75":6,"i76":6,"i77":6,"i78":6,"i79":6,"i80":6,"i81":6,"i82":6,"i83":6,"i84":6,"i85":6,"i86":6,"i87":6,"i88":6,"i89":6,"i90":6,"i91":18,"i92":6,"i93":38,"i94":38,"i95":38,"i96":6,"i97":6,"i98":6,"i99":6,"i100":6,"i101":6,"i102":6,"i103":6,"i104":6,"i105":6,"i106":6,"i107":6,"i108":6,"i109":6,"i110":6,"i111":6,"i112":6,"i113":6,"i114":6,"i115":18,"i116":18,"i117":18,"i
118":6,"i119":6,"i120":6,"i121":6,"i122":6,"i123":6,"i124":6,"i125":6,"i126":6,"i127":6,"i128":6,"i129":38,"i130":6,"i131":6,"i132":6,"i133":6,"i134":6,"i135":6,"i136":38,"i137":38,"i138":38,"i139":38,"i140":38,"i141":6,"i142":6,"i143":6,"i144":6,"i145":6,"i146":6,"i147":6,"i148":6,"i149":38,"i150":6,"i151":6,"i152":38,"i153":6,"i154":6,"i155":6,"i156":6,"i157":6,"i158":38,"i159":6,"i160":38,"i161":6,"i162":6,"i163":6,"i164":6,"i165":18,"i166":18,"i167":6,"i168":6,"i169":6,"i170":6,"i171":6,"i172":6,"i173":6,"i174":6,"i175":6,"i176":6,"i177":6,"i178":6,"i179":6,"i180":6,"i181":6,"i182":6,"i183":6,"i184":6,"i185":6,"i186":6,"i187":6,"i188":38,"i189":38,"i190":6,"i191":6,"i192":6,"i193":6,"i194":6,"i195":6,"i196":6,"i197":6,"i198":6,"i199":6,"i200":18};
+var methods =
{"i0":6,"i1":6,"i2":6,"i3":38,"i4":6,"i5":6,"i6":18,"i7":18,"i8":6,"i9":6,"i10":6,"i11":6,"i12":6,"i13":6,"i14":6,"i15":6,"i16":6,"i17":38,"i18":38,"i19":38,"i20":38,"i21":6,"i22":6,"i23":6,"i24":6,"i25":6,"i26":6,"i27":6,"i28":6,"i29":6,"i30":6,"i31":6,"i32":50,"i33":50,"i34":50,"i35":6,"i36":6,"i37":6,"i38":50,"i39":6,"i40":38,"i41":6,"i42":6,"i43":6,"i44":6,"i45":6,"i46":6,"i47":6,"i48":6,"i49":6,"i50":6,"i51":38,"i52":38,"i53":6,"i54":6,"i55":18,"i56":6,"i57":6,"i58":6,"i59":38,"i60":38,"i61":6,"i62":6,"i63":18,"i64":6,"i65":6,"i66":6,"i67":38,"i68":38,"i69":6,"i70":6,"i71":6,"i72":6,"i73":38,"i74":6,"i75":6,"i76":6,"i77":6,"i78":6,"i79":6,"i80":6,"i81":6,"i82":6,"i83":6,"i84":6,"i85":6,"i86":6,"i87":6,"i88":6,"i89":6,"i90":6,"i91":6,"i92":18,"i93":6,"i94":38,"i95":38,"i96":38,"i97":6,"i98":6,"i99":6,"i100":6,"i101":6,"i102":6,"i103":6,"i104":6,"i105":6,"i106":6,"i107":6,"i108":6,"i109":6,"i110":6,"i111":6,"i112":6,"i113":6,"i114":6,"i115":6,"i116":18,"i117":18,"i1
18":18,"i119":6,"i120":6,"i121":6,"i122":6,"i123":6,"i124":6,"i125":6,"i126":6,"i127":6,"i128":6,"i129":6,"i130":38,"i131":6,"i132":6,"i133":6,"i134":6,"i135":6,"i136":6,"i137":38,"i138":38,"i139":38,"i140":38,"i141":38,"i142":6,"i143":6,"i144":6,"i145":6,"i146":6,"i147":6,"i148":6,"i149":6,"i150":38,"i151":6,"i152":6,"i153":38,"i154":6,"i155":6,"i156":6,"i157":6,"i158":6,"i159":38,"i160":6,"i161":38,"i162":6,"i163":6,"i164":6,"i165":6,"i166":18,"i167":18,"i168":6,"i169":6,"i170":6,"i171":6,"i172":6,"i173":6,"i174":6,"i175":6,"i176":6,"i177":6,"i178":6,"i179":6,"i180":6,"i181":6,"i182":6,"i183":6,"i184":6,"i185":6,"i186":6,"i187":6,"i188":6,"i189":38,"i190":38,"i191":6,"i192":6,"i193":6,"i194":6,"i195":6,"i196":6,"i197":6,"i198":6,"i199":6,"i200":6,"i201":18};
var tabs = {65535:["t0","All Methods"],2:["t2","Instance
Methods"],4:["t3","Abstract Methods"],16:["t5","Default
Methods"],32:["t6","Deprecated Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
@@ -110,7 +110,7 @@ var activeTableTab = "activeTableTab";
@InterfaceAudience.Public
-public interface Admin
+public interface Admin
extends Abortable, http://docs.oracle.com/javase/8/docs/api/java/io/Closeable.html?is-external=true;
title="class or interface in java.io">Closeable
The administrative API for HBase. Obtain an instance from
an Connection.getAdmin()
and
call close()
afterwards.
@@ -705,33 +705,39 @@ extends getClusterStatus()
+ClusterStatus
+getClusterStatus(ClusterStatus.Optionsoptions)
+Get cluster status with options to filter out unwanted
status.
+
+
+
CompactionState
getCompactionState(TableNametableName)
Get the current compaction state of a table.
-
+
CompactionState
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8bae1c8a/devapidocs/org/apache/hadoop/hbase/class-use/ServerName.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/ServerName.html
b/devapidocs/org/apache/hadoop/hbase/class-use/ServerName.html
index dda7356..46a7e99 100644
--- a/devapidocs/org/apache/hadoop/hbase/class-use/ServerName.html
+++ b/devapidocs/org/apache/hadoop/hbase/class-use/ServerName.html
@@ -212,10 +212,14 @@
private ServerName
-SplitLogTask.originServer
+ClusterStatus.Builder.master
private ServerName
+SplitLogTask.originServer
+
+
+private ServerName
HRegionLocation.serverName
@@ -233,8 +237,16 @@
private http://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true;
title="class or interface in java.util">CollectionServerName
+ClusterStatus.Builder.backupMasters
+
+
+private http://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true;
title="class or interface in java.util">CollectionServerName
ClusterStatus.deadServers
+
+private http://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true;
title="class or interface in java.util">CollectionServerName
+ClusterStatus.Builder.deadServers
+
static http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true;
title="class or interface in java.util">ListServerName
ServerName.EMPTY_SERVER_LIST
@@ -243,6 +255,10 @@
private http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true;
title="class or interface in java.util">MapServerName,ServerLoad
ClusterStatus.liveServers
+
+private http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true;
title="class or interface in java.util">MapServerName,ServerLoad
+ClusterStatus.Builder.liveServers
+
@@ -463,6 +479,10 @@
+ClusterStatus.Builder
+ClusterStatus.Builder.setMaster(ServerNamemaster)
+
+
static void
MetaTableAccessor.splitRegion(Connectionconnection,
HRegionInfoparent,
@@ -474,7 +494,7 @@
Splits the region into two in an atomic operation.
-
+
private static void
MetaTableAccessor.updateLocation(Connectionconnection,
HRegionInforegionInfo,
@@ -484,7 +504,7 @@
Updates the location of the specified region to be the
specified server.
-
+
static void
MetaTableAccessor.updateRegionLocation(Connectionconnection,
HRegionInforegionInfo,
@@ -508,6 +528,18 @@
(package private) static http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true;
title="class or interface in java.util">ListHRegionInfo
MetaTableAccessor.getListOfHRegionInfos(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true;
title="class or interface in java.util">ListPairHRegionInfo,ServerNamepairs)
+
+ClusterStatus.Builder
+ClusterStatus.Builder.setBackupMasters(http://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true;
title="class or interface in java.util">CollectionServerNamebackupMasters)
+
+
+ClusterStatus.Builder
+ClusterStatus.Builder.setDeadServers(http://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true;
title="class or interface in java.util">CollectionServerNamedeadServers)
+
+
+ClusterStatus.Builder
+ClusterStatus.Builder.setLiveServers(http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true;
title="class or interface in java.util">MapServerName,ServerLoadliveServers)
+
@@ -525,7 +557,12 @@
http://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true;
title="class or interface in java.util">CollectionServerNamebackupMasters,
http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true;
title="class or interface in java.util">ListRegionStaterit,
http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String[]masterCoprocessors,
- http://docs.oracle.com/javase/8/docs/api/java/lang/Boolean.html?is-external=true;
title="class or interface in
java.lang">BooleanbalancerOn)
+ http://docs.oracle.com/javase/8/docs/api/java/lang/Boolean.html?is-external=true;
title="class or interface in java.lang">BooleanbalancerOn)
+Deprecated.
+As of release 2.0.0, this
will be removed in HBase 3.0.0
+ (https://issues.apache.org/jira/browse/HBASE-15511;>HBASE-15511).
+
+
Done(ServerNameoriginServer,
@@ -581,7 +618,12 @@
http://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true;
title="class or interface in java.util">CollectionServerNamebackupMasters,
http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true;
title="class or interface in java.util">ListRegionStaterit,
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8bae1c8a/devapidocs/constant-values.html
--
diff --git a/devapidocs/constant-values.html b/devapidocs/constant-values.html
index bb57548..fd61d3e 100644
--- a/devapidocs/constant-values.html
+++ b/devapidocs/constant-values.html
@@ -3836,21 +3836,21 @@
publicstaticfinalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String
date
-"Sat Aug 12 14:41:08 UTC 2017"
+"Mon Aug 14 14:40:45 UTC 2017"
publicstaticfinalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String
revision
-"173dce73471da005fb6780a7e7b65b43bad481e2"
+"e2b797be390f05c55a490a64bc72e2d8c19fcbb7"
publicstaticfinalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String
srcChecksum
-"0b5fe4e50617b899e986f38527f3404c"
+"5941cfcfb586bba33a288c7c32efc33d"
@@ -4206,6 +4206,13 @@
"hbase.backup.copy.class"
+
+
+publicstaticfinalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String
+HBASE_BACKUP_MERGE_IMPL_CLASS
+"hbase.backup.merge.class"
+
+
publicstaticfinalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String
@@ -4387,48 +4394,55 @@
"Incorrect usage"
+
+
+publicstaticfinalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String
+MERGE_CMD_USAGE
+"Usage: hbase backup merge [backup_ids]\n
backup_ids Comma separated list of backup image ids.\n"
+
+
publicstaticfinalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String
NO_ACTIVE_SESSION_FOUND
"No active backup sessions found."
-
+
publicstaticfinalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String
NO_INFO_FOUND
"No info was found for backup id: "
-
+
publicstaticfinalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String
PROGRESS_CMD_USAGE
"Usage: hbase backup progress backup_id\n
backup_id Backup image id (optional). If no id specified, the command
will show\n progress for currently running backup
session."
-
+
publicstaticfinalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String
REPAIR_CMD_USAGE
"Usage: hbase backup repair\n"
-
+
publicstaticfinalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String
SET_CMD_USAGE
"Usage: hbase backup set COMMAND [name] [tables]\n
nameBackup set name\n tables Comma separated list of
tables.\nCOMMAND is one of:\n add add tables to a set, create a
set if needed\n remove remove tables from a set\n list
list all backup sets in the system\n describedescribe set\n delete
delete backup set\n"
-
+
publicstaticfinalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String
USAGE
-"Usage: hbase backup COMMAND [command-specific
arguments]\nwhere COMMAND is one of:\n create create a new backup image\n
delete delete an existing backup image\n describe show the detailed
information of a backup image\n historyshow history of all successful
backups\n progress show the progress of the latest backup request\n set
backup set management\n repair repair backup system tableRun \'hbase
backup COMMAND -h\' to see help message for each command\n"
+"Usage: hbase backup COMMAND [command-specific
arguments]\nwhere COMMAND is one of:\n create create a new backup image\n
delete delete an existing backup image\n describe show the detailed
information of a backup image\n historyshow history of all successful
backups\n progress show the progress of the latest backup request\n set
backup set management\n repair repair backup system table\n merge
merge backup images\nRun \'hbase backup COMMAND -h\' to see help message for
each command\n"
-
+
publicstaticfinalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String
@@ -4635,7 +4649,7 @@
-org.apache.hadoop.hbase.backup.mapreduce.HFileSplitterJob
+org.apache.hadoop.hbase.backup.mapreduce.MapReduceHFileSplitterJob
Modifier and Type
Constant Field
@@ -4643,38 +4657,38 @@
-
+
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8bae1c8a/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.html
b/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.html
index 67131e4..d59138d 100644
--- a/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.html
+++ b/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.html
@@ -18,7 +18,7 @@
catch(err) {
}
//-->
-var methods =
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10,"i35":10,"i36":10,"i37":10,"i38":10,"i39":10,"i40":10,"i41":10,"i42":10,"i43":10,"i44":10,"i45":10,"i46":10,"i47":10,"i48":10,"i49":10,"i50":10,"i51":10,"i52":10,"i53":10,"i54":10,"i55":10,"i56":10,"i57":10,"i58":10,"i59":10,"i60":10,"i61":10,"i62":10,"i63":10,"i64":10,"i65":10,"i66":10,"i67":10,"i68":10,"i69":10,"i70":10,"i71":10,"i72":10,"i73":10,"i74":10,"i75":10,"i76":10,"i77":10,"i78":10,"i79":10,"i80":10,"i81":10,"i82":10,"i83":10,"i84":10,"i85":10,"i86":10,"i87":10,"i88":10,"i89":10,"i90":10,"i91":10,"i92":10,"i93":10,"i94":10,"i95":10,"i96":10,"i97":10,"i98":10,"i99":10,"i100":10,"i101":10,"i102":10,"i103":10,"i104":10,"i105":10,"i106":10,"i107":10};
+var methods =
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10,"i35":10,"i36":10,"i37":10,"i38":10,"i39":10,"i40":10,"i41":10,"i42":10,"i43":10,"i44":10,"i45":10,"i46":10,"i47":10,"i48":10,"i49":10,"i50":10,"i51":10,"i52":10,"i53":10,"i54":10,"i55":10,"i56":10,"i57":10,"i58":10,"i59":10,"i60":10,"i61":10,"i62":10,"i63":10,"i64":10,"i65":10,"i66":10,"i67":10,"i68":10,"i69":10,"i70":10,"i71":10,"i72":10,"i73":10,"i74":10,"i75":10,"i76":10,"i77":10,"i78":10,"i79":10,"i80":10,"i81":10,"i82":10,"i83":10,"i84":10,"i85":10,"i86":10,"i87":10,"i88":10,"i89":10,"i90":10,"i91":10,"i92":10,"i93":10,"i94":10,"i95":10,"i96":10,"i97":10,"i98":10,"i99":10,"i100":10,"i101":10,"i102":10,"i103":10,"i104":10,"i105":10,"i106":10,"i107":10,"i108":10};
var tabs = {65535:["t0","All Methods"],2:["t2","Instance
Methods"],8:["t4","Concrete Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
@@ -114,7 +114,7 @@ var activeTableTab = "activeTableTab";
@InterfaceAudience.Private
-public class AsyncHBaseAdmin
+public class AsyncHBaseAdmin
extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true;
title="class or interface in java.lang">Object
implements AsyncAdmin
The implementation of AsyncAdmin.
@@ -418,113 +418,117 @@ implements getClusterStatus()
+http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true;
title="class or interface in java.util.concurrent">CompletableFutureClusterStatus
+getClusterStatus(ClusterStatus.Optionsoptions)
+
+
http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true;
title="class or interface in java.util.concurrent">CompletableFutureCompactionState
getCompactionState(TableNametableName)
Get the current compaction state of a table.
-
+
http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true;
title="class or interface in java.util.concurrent">CompletableFutureCompactionState
getCompactionStateForRegion(byte[]regionName)
Get the current compaction state of region.
-
+
http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true;
title="class or interface in java.util.concurrent">CompletableFuturehttp://docs.oracle.com/javase/8/docs/api/java/util/Optional.html?is-external=true;
title="class or interface in java.util">Optionalhttp://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true;
title="class or interface in java.lang">Long
getLastMajorCompactionTimestamp(TableNametableName)
Get the timestamp of the last major compaction for the
passed table.
-
+
http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true;
title="class or interface in java.util.concurrent">CompletableFuturehttp://docs.oracle.com/javase/8/docs/api/java/util/Optional.html?is-external=true;
title="class or interface in java.util">Optionalhttp://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true;
title="class or interface in java.lang">Long
getLastMajorCompactionTimestampForRegion(byte[]regionName)
Get the timestamp of the
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8bae1c8a/devapidocs/org/apache/hadoop/hbase/io/asyncfs/FanOutOneBlockAsyncDFSOutputSaslHelper.html
--
diff --git
a/devapidocs/org/apache/hadoop/hbase/io/asyncfs/FanOutOneBlockAsyncDFSOutputSaslHelper.html
b/devapidocs/org/apache/hadoop/hbase/io/asyncfs/FanOutOneBlockAsyncDFSOutputSaslHelper.html
index a39f56f..db18883 100644
---
a/devapidocs/org/apache/hadoop/hbase/io/asyncfs/FanOutOneBlockAsyncDFSOutputSaslHelper.html
+++
b/devapidocs/org/apache/hadoop/hbase/io/asyncfs/FanOutOneBlockAsyncDFSOutputSaslHelper.html
@@ -286,13 +286,13 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
private static void
-doSaslNegotiation(org.apache.hadoop.conf.Configurationconf,
- io.netty.channel.Channelchannel,
+doSaslNegotiation(org.apache.hadoop.conf.Configurationconf,
+
org.apache.hadoop.hbase.shaded.io.netty.channel.Channelchannel,
inttimeoutMs,
http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">Stringusername,
char[]password,
http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true;
title="class or interface in java.util">Maphttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String,http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">StringsaslProps,
- io.netty.util.concurrent.Promisehttp://docs.oracle.com/javase/8/docs/api/java/lang/Void.html?is-external=true;
title="class or interface in
java.lang">VoidsaslPromise)
+
org.apache.hadoop.hbase.shaded.io.netty.util.concurrent.Promisehttp://docs.oracle.com/javase/8/docs/api/java/lang/Void.html?is-external=true;
title="class or interface in
java.lang">VoidsaslPromise)
private static char[]
@@ -304,13 +304,13 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
(package private) static void
-trySaslNegotiate(org.apache.hadoop.conf.Configurationconf,
-io.netty.channel.Channelchannel,
+trySaslNegotiate(org.apache.hadoop.conf.Configurationconf,
+
org.apache.hadoop.hbase.shaded.io.netty.channel.Channelchannel,
org.apache.hadoop.hdfs.protocol.DatanodeInfodnInfo,
inttimeoutMs,
org.apache.hadoop.hdfs.DFSClientclient,
org.apache.hadoop.security.token.Tokenorg.apache.hadoop.hdfs.security.token.block.BlockTokenIdentifieraccessToken,
-io.netty.util.concurrent.Promisehttp://docs.oracle.com/javase/8/docs/api/java/lang/Void.html?is-external=true;
title="class or interface in
java.lang">VoidsaslPromise)
+
org.apache.hadoop.hbase.shaded.io.netty.util.concurrent.Promisehttp://docs.oracle.com/javase/8/docs/api/java/lang/Void.html?is-external=true;
title="class or interface in
java.lang">VoidsaslPromise)
@@ -549,34 +549,34 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
private statichttp://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true;
title="class or interface in java.util">Maphttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String,http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">StringcreateSaslPropertiesForEncryption(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in
java.lang">StringencryptionAlgorithm)
-
+
doSaslNegotiation
private staticvoiddoSaslNegotiation(org.apache.hadoop.conf.Configurationconf,
- io.netty.channel.Channelchannel,
+
org.apache.hadoop.hbase.shaded.io.netty.channel.Channelchannel,
inttimeoutMs,
http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">Stringusername,
char[]password,
http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true;
title="class or interface in java.util">Maphttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String,http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">StringsaslProps,
- io.netty.util.concurrent.Promisehttp://docs.oracle.com/javase/8/docs/api/java/lang/Void.html?is-external=true;
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8bae1c8a/devapidocs/org/apache/hadoop/hbase/backup/util/BackupUtils.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/backup/util/BackupUtils.html
b/devapidocs/org/apache/hadoop/hbase/backup/util/BackupUtils.html
index 2088d7e..97cc4c6 100644
--- a/devapidocs/org/apache/hadoop/hbase/backup/util/BackupUtils.html
+++ b/devapidocs/org/apache/hadoop/hbase/backup/util/BackupUtils.html
@@ -18,7 +18,7 @@
catch(err) {
}
//-->
-var methods =
{"i0":9,"i1":9,"i2":9,"i3":9,"i4":9,"i5":9,"i6":9,"i7":9,"i8":9,"i9":9,"i10":9,"i11":9,"i12":9,"i13":9,"i14":9,"i15":9,"i16":9,"i17":9,"i18":9,"i19":9,"i20":9,"i21":9,"i22":9,"i23":9,"i24":9,"i25":9,"i26":9,"i27":9};
+var methods =
{"i0":9,"i1":9,"i2":9,"i3":9,"i4":9,"i5":9,"i6":9,"i7":9,"i8":9,"i9":9,"i10":9,"i11":9,"i12":9,"i13":9,"i14":9,"i15":9,"i16":9,"i17":9,"i18":9,"i19":9,"i20":9,"i21":9,"i22":9,"i23":9,"i24":9,"i25":9,"i26":9,"i27":9,"i28":9,"i29":9,"i30":9,"i31":9,"i32":9,"i33":9};
var tabs = {65535:["t0","All Methods"],1:["t1","Static
Methods"],8:["t4","Concrete Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
@@ -110,7 +110,7 @@ var activeTableTab = "activeTableTab";
@InterfaceAudience.Private
-public final class BackupUtils
+public final class BackupUtils
extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true;
title="class or interface in java.lang">Object
A collection for methods used by multiple classes to backup
HBase tables.
@@ -139,6 +139,10 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
static http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String
LOGNAME_SEPARATOR
+
+static int
+MILLISEC_IN_HOUR
+
@@ -209,11 +213,15 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
copyTableRegionInfo(Connectionconn,
BackupInfobackupInfo,
org.apache.hadoop.conf.Configurationconf)
-copy out Table RegionInfo into incremental backup image
need to consider move this
- logic into HBackupFileSystem
+copy out Table RegionInfo into incremental backup image
need to consider move this logic into
+ HBackupFileSystem
+static LoadIncrementalHFiles
+createLoader(org.apache.hadoop.conf.Configurationconfig)
+
+
static RestoreRequest
createRestoreRequest(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">StringbackupRootDir,
http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">StringbackupId,
@@ -224,39 +232,58 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
Create restore request.
-
+
+static boolean
+failed(intresult)
+
+
+static org.apache.hadoop.fs.Path
+getBulkOutputDir(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">StringtableName,
+
org.apache.hadoop.conf.Configurationconf)
+
+
+static org.apache.hadoop.fs.Path
+getBulkOutputDir(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">StringtableName,
+org.apache.hadoop.conf.Configurationconf,
+booleandeleteOnExit)
+
+
static http://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true;
title="class or interface in java.lang">Long
getCreationTime(org.apache.hadoop.fs.Pathp)
Given the log file, parse the timestamp from the file
name.
-
+
+static http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String
+getFileNameCompatibleString(TableNametable)
+
+
static http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true;
title="class or interface in java.util">Listhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String
getFiles(org.apache.hadoop.fs.FileSystemfs,
org.apache.hadoop.fs.PathrootDir,
http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true;
title="class or interface in java.util">Listhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">Stringfiles,
org.apache.hadoop.fs.PathFilterfilter)
-
+
static long
getFilesLength(org.apache.hadoop.fs.FileSystemfs,
org.apache.hadoop.fs.Pathdir)
Get the total length of files under the given directory
recursively.
-
+
static http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true;
title="class or interface in java.util">ListBackupInfo
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8bae1c8a/apidocs/org/apache/hadoop/hbase/ClusterStatus.html
--
diff --git a/apidocs/org/apache/hadoop/hbase/ClusterStatus.html
b/apidocs/org/apache/hadoop/hbase/ClusterStatus.html
index 6670825..504733b 100644
--- a/apidocs/org/apache/hadoop/hbase/ClusterStatus.html
+++ b/apidocs/org/apache/hadoop/hbase/ClusterStatus.html
@@ -18,8 +18,8 @@
catch(err) {
}
//-->
-var methods =
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":42,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10};
-var tabs = {65535:["t0","All Methods"],2:["t2","Instance
Methods"],8:["t4","Concrete Methods"],32:["t6","Deprecated Methods"]};
+var methods =
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":42,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":9,"i23":10};
+var tabs = {65535:["t0","All Methods"],1:["t1","Static
Methods"],2:["t2","Instance Methods"],8:["t4","Concrete
Methods"],32:["t6","Deprecated Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
var tableTab = "tableTab";
@@ -119,7 +119,7 @@ var activeTableTab = "activeTableTab";
@InterfaceAudience.Public
-public class ClusterStatus
+public class ClusterStatus
extends org.apache.hadoop.io.VersionedWritable
Status information on the HBase cluster.
@@ -136,7 +136,29 @@ extends org.apache.hadoop.io.VersionedWritable
per server and per region.
Regions in transition at master
The unique cluster ID
-
+
+ ClusterStatus.Options provides a way to filter out
infos which unwanted.
+ The following codes will retrieve all the cluster information.
+
+
+ // Original version still works
+ Admin admin = connection.getAdmin();
+ ClusterStatus status = admin.getClusterStatus();
+ // or below, a new version which has the same effects
+ ClusterStatus status = admin.getClusterStatus(Options.defaultOptions());
+
+
+ If information about dead servers and master coprocessors are unwanted,
+ then codes in the following way:
+
+
+ Admin admin = connection.getAdmin();
+ ClusterStatus status = admin.getClusterStatus(
+Options.defaultOptions()
+ .excludeDeadServers()
+ .excludeMasterCoprocessors());
+
+
@@ -163,7 +185,12 @@ extends org.apache.hadoop.io.VersionedWritable
http://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true;
title="class or interface in java.util">CollectionServerNamebackupMasters,
http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true;
title="class or interface in
java.util">Listorg.apache.hadoop.hbase.master.RegionStaterit,
http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String[]masterCoprocessors,
- http://docs.oracle.com/javase/8/docs/api/java/lang/Boolean.html?is-external=true;
title="class or interface in
java.lang">BooleanbalancerOn)
+ http://docs.oracle.com/javase/8/docs/api/java/lang/Boolean.html?is-external=true;
title="class or interface in java.lang">BooleanbalancerOn)
+Deprecated.
+As of release 2.0.0, this
will be removed in HBase 3.0.0
+ (https://issues.apache.org/jira/browse/HBASE-15511;>HBASE-15511).
+
+
@@ -175,7 +202,7 @@ extends org.apache.hadoop.io.VersionedWritable
Method Summary
-All MethodsInstance MethodsConcrete MethodsDeprecated Methods
+All MethodsStatic MethodsInstance MethodsConcrete MethodsDeprecated Methods
Modifier and Type
Method and Description
@@ -277,6 +304,10 @@ extends org.apache.hadoop.io.VersionedWritable
isBalancerOn()
+static
org.apache.hadoop.hbase.ClusterStatus.Builder
+newBuilder()
+
+
http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String
toString()
@@ -315,15 +346,19 @@ extends org.apache.hadoop.io.VersionedWritable
ClusterStatus
-publicClusterStatus(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">StringhbaseVersion,
- http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">Stringclusterid,
- http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true;
title="class or interface in java.util">MapServerName,ServerLoadservers,
- http://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true;
title="class or interface in java.util">CollectionServerNamedeadServers,
- ServerNamemaster,
-
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8bae1c8a/devapidocs/org/apache/hadoop/hbase/backup/BackupInfo.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/backup/BackupInfo.html
b/devapidocs/org/apache/hadoop/hbase/backup/BackupInfo.html
index 204b832..cb30554 100644
--- a/devapidocs/org/apache/hadoop/hbase/backup/BackupInfo.html
+++ b/devapidocs/org/apache/hadoop/hbase/backup/BackupInfo.html
@@ -18,7 +18,7 @@
catch(err) {
}
//-->
-var methods =
{"i0":10,"i1":10,"i2":10,"i3":9,"i4":9,"i5":9,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10,"i35":10,"i36":10,"i37":10,"i38":10,"i39":10,"i40":10,"i41":10,"i42":10,"i43":10,"i44":10,"i45":10,"i46":10,"i47":10,"i48":10,"i49":10,"i50":10,"i51":10,"i52":10,"i53":10,"i54":9,"i55":10};
+var methods =
{"i0":10,"i1":10,"i2":10,"i3":9,"i4":9,"i5":9,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10,"i35":10,"i36":10,"i37":10,"i38":10,"i39":10,"i40":10,"i41":10,"i42":10,"i43":10,"i44":10,"i45":10,"i46":10,"i47":10,"i48":10,"i49":10,"i50":10,"i51":10,"i52":10,"i53":10,"i54":9,"i55":10,"i56":10};
var tabs = {65535:["t0","All Methods"],1:["t1","Static
Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
@@ -542,13 +542,17 @@ implements http://docs.oracle.com/javase/8/docs/api/java/lang/Comparabl
org.apache.hadoop.hbase.shaded.protobuf.generated.BackupProtos.BackupInfo
toProtosBackupInfo()
+
+http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String
+toString()
+
Methods inherited from classjava.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true;
title="class or interface in java.lang">Object
-http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#clone--;
title="class or interface in java.lang">clone, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#finalize--;
title="class or interface in java.lang">finalize, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#getClass--;
title="class or interface in java.lang">getClass, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#notify--;
title="class or interface in java.lang">notify, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#notifyAll--;
title="class or interface in java.lang">notifyAll, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#toString--;
title="class or interface in java.lang">toString, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.ht
ml?is-external=true#wait--" title="class or interface in java.lang">wait,
http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait-long-;
title="class or interface in java.lang">wait, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait-long-int-;
title="class or interface in java.lang">wait
+http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#clone--;
title="class or interface in java.lang">clone, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#finalize--;
title="class or interface in java.lang">finalize, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#getClass--;
title="class or interface in java.lang">getClass, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#notify--;
title="class or interface in java.lang">notify, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#notifyAll--;
title="class or interface in java.lang">notifyAll, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait--;
title="class or interface in java.lang">wait, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-ex
ternal=true#wait-long-" title="class or interface in java.lang">wait, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait-long-int-;
title="class or interface in java.lang">wait
@@ -1210,13 +1214,26 @@ implements http://docs.oracle.com/javase/8/docs/api/java/lang/Comparabl
+
+
+
+
+
+toString
+publichttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">StringtoString()
+
+Overrides:
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8bae1c8a/apidocs/src-html/org/apache/hadoop/hbase/client/AsyncAdmin.html
--
diff --git a/apidocs/src-html/org/apache/hadoop/hbase/client/AsyncAdmin.html
b/apidocs/src-html/org/apache/hadoop/hbase/client/AsyncAdmin.html
index 477e3fa..2ab3342 100644
--- a/apidocs/src-html/org/apache/hadoop/hbase/client/AsyncAdmin.html
+++ b/apidocs/src-html/org/apache/hadoop/hbase/client/AsyncAdmin.html
@@ -35,1087 +35,1093 @@
027import java.util.regex.Pattern;
028
029import
org.apache.hadoop.hbase.ClusterStatus;
-030import
org.apache.hadoop.hbase.HRegionInfo;
-031import
org.apache.hadoop.hbase.ProcedureInfo;
-032import
org.apache.hadoop.hbase.RegionLoad;
-033import
org.apache.hadoop.hbase.ServerName;
-034import
org.apache.hadoop.hbase.NamespaceDescriptor;
-035import
org.apache.hadoop.hbase.TableName;
-036import
org.apache.hadoop.hbase.classification.InterfaceAudience;
-037import
org.apache.hadoop.hbase.procedure2.LockInfo;
-038import
org.apache.hadoop.hbase.quotas.QuotaFilter;
-039import
org.apache.hadoop.hbase.quotas.QuotaSettings;
-040import
org.apache.hadoop.hbase.client.RawAsyncTable.CoprocessorCallable;
-041import
org.apache.hadoop.hbase.client.replication.TableCFs;
-042import
org.apache.hadoop.hbase.client.security.SecurityCapability;
-043import
org.apache.hadoop.hbase.replication.ReplicationPeerConfig;
-044import
org.apache.hadoop.hbase.replication.ReplicationPeerDescription;
-045import
org.apache.hadoop.hbase.util.Pair;
-046
-047import com.google.protobuf.RpcChannel;
-048
-049/**
-050 * The asynchronous administrative API
for HBase.
-051 * p
-052 * This feature is still under
development, so marked as IA.Private. Will change to public when
-053 * done. Use it with caution.
-054 */
-055@InterfaceAudience.Public
-056public interface AsyncAdmin {
-057
-058 /**
-059 * @param tableName Table to check.
-060 * @return True if table exists
already. The return value will be wrapped by a
-061 * {@link CompletableFuture}.
-062 */
-063 CompletableFutureBoolean
tableExists(TableName tableName);
-064
-065 /**
-066 * List all the userspace tables.
-067 * @return - returns a list of
TableDescriptors wrapped by a {@link CompletableFuture}.
-068 * @see #listTables(Optional,
boolean)
-069 */
-070 default
CompletableFutureListTableDescriptor listTables() {
-071return listTables(Optional.empty(),
false);
-072 }
-073
-074 /**
-075 * List all the tables matching the
given pattern.
-076 * @param pattern The compiled regular
expression to match against
-077 * @param includeSysTables False to
match only against userspace tables
-078 * @return - returns a list of
TableDescriptors wrapped by a {@link CompletableFuture}.
-079 */
-080
CompletableFutureListTableDescriptor
listTables(OptionalPattern pattern,
-081 boolean includeSysTables);
-082
-083 /**
-084 * List all of the names of userspace
tables.
-085 * @return a list of table names
wrapped by a {@link CompletableFuture}.
-086 * @see #listTableNames(Optional,
boolean)
-087 */
-088 default
CompletableFutureListTableName listTableNames() {
-089return
listTableNames(Optional.empty(), false);
-090 }
-091
-092 /**
-093 * List all of the names of userspace
tables.
-094 * @param pattern The regular
expression to match against
-095 * @param includeSysTables False to
match only against userspace tables
-096 * @return a list of table names
wrapped by a {@link CompletableFuture}.
-097 */
-098
CompletableFutureListTableName
listTableNames(OptionalPattern pattern,
-099 boolean includeSysTables);
-100
-101 /**
-102 * Method for getting the
tableDescriptor
-103 * @param tableName as a {@link
TableName}
-104 * @return the read-only
tableDescriptor wrapped by a {@link CompletableFuture}.
-105 */
-106
CompletableFutureTableDescriptor getTableDescriptor(TableName
tableName);
-107
-108 /**
-109 * Creates a new table.
-110 * @param desc table descriptor for
table
-111 */
-112 default CompletableFutureVoid
createTable(TableDescriptor desc) {
-113return createTable(desc,
Optional.empty());
-114 }
-115
-116 /**
-117 * Creates a new table with the
specified number of regions. The start key specified will become
-118 * the end key of the first region of
the table, and the end key specified will become the start
-119 * key of the last region of the table
(the first region has a null start key and the last region
-120 * has a null end key). BigInteger math
will be used to divide the key range specified into enough
-121 * segments to make the required number
of total regions.
-122 * @param desc table descriptor for
table
-123 * @param startKey beginning of key
range
-124 * @param endKey end of key range
-125 * @param numRegions the total number
of regions to create
-126 */
-127 CompletableFutureVoid
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8bae1c8a/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupAdminImpl.html
--
diff --git
a/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupAdminImpl.html
b/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupAdminImpl.html
index 2167678..cb9af32 100644
--- a/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupAdminImpl.html
+++ b/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupAdminImpl.html
@@ -18,7 +18,7 @@
catch(err) {
}
//-->
-var methods =
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10};
+var methods =
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10};
var tabs = {65535:["t0","All Methods"],2:["t2","Instance
Methods"],8:["t4","Concrete Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
@@ -114,7 +114,7 @@ var activeTableTab = "activeTableTab";
@InterfaceAudience.Private
-public class BackupAdminImpl
+public class BackupAdminImpl
extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true;
title="class or interface in java.lang">Object
implements BackupAdmin
@@ -198,122 +198,135 @@ implements
private void
+checkIfValidForMerge(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String[]backupIds,
+BackupSystemTabletable)
+Verifies that backup images are valid for merge.
+
+
+
+private void
cleanupBackupDir(BackupInfobackupInfo,
TableNametable,
org.apache.hadoop.conf.Configurationconf)
Clean up the data at target directory
-
+
void
close()
-
+
private int
deleteBackup(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">StringbackupId,
BackupSystemTablesysTable)
Delete single backup and all related backups
Algorithm:
- Backup type: FULL or INCREMENTAL
- Is this last backup session for table T: YES or NO
- For every table T from table list 'tables':
- if(FULL, YES) deletes only physical data (PD)
- if(FULL, NO), deletes PD, scans all newer backups and removes T from
backupInfo,
- until we either reach the most recent backup for T in the system or FULL
backup
- which includes T
- if(INCREMENTAL, YES) deletes only physical data (PD)
- if(INCREMENTAL, NO) deletes physical data and for table T scans all backup
images between last
- FULL backup, which is older than the backup being deleted and the next FULL
backup (if exists)
- or last one for a particular table T and removes T from list of backup
tables.
+ Backup type: FULL or INCREMENTAL
+ Is this last backup session for table T: YES or NO
+ For every table T from table list 'tables':
+ if(FULL, YES) deletes only physical data (PD)
+ if(FULL, NO), deletes PD, scans all newer backups and removes T from
backupInfo,
+ until we either reach the most recent backup for T in the system or FULL
backup
+ which includes T
+ if(INCREMENTAL, YES) deletes only physical data (PD) if(INCREMENTAL, NO)
deletes physical data
+ and for table T scans all backup images between last
+ FULL backup, which is older than the backup being deleted and the next FULL
backup (if exists)
+ or last one for a particular table T and removes T from list of backup
tables.
-
+
int
deleteBackups(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String[]backupIds)
Delete backup image command
-
+
boolean
deleteBackupSet(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">Stringname)
Delete backup set command
-
+
private http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true;
title="class or interface in java.util">ListTableName
excludeNonExistingTables(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true;
title="class or interface in java.util">ListTableNametableList,
http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true;
title="class or interface in java.util">ListTableNamenonExistingTableList)
-
+
private void
finalizeDelete(http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true;
title="class or interface in java.util">Maphttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String,http://docs.oracle.com/javase/8/docs/api/java/util/HashSet.html?is-external=true;
title="class or interface in java.util">HashSetTableNametablesMap,
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8bae1c8a/devapidocs/index-all.html
--
diff --git a/devapidocs/index-all.html b/devapidocs/index-all.html
index 54d424b..bd4d91b 100644
--- a/devapidocs/index-all.html
+++ b/devapidocs/index-all.html
@@ -2813,7 +2813,7 @@
Find a bucket to allocate a block
-allocateBuffer(ChannelHandlerContext,
ByteBuf, boolean) - Method in class
org.apache.hadoop.hbase.io.asyncfs.FanOutOneBlockAsyncDFSOutputSaslHelper.EncryptHandler
+allocateBuffer(ChannelHandlerContext,
ByteBuf, boolean) - Method in class
org.apache.hadoop.hbase.io.asyncfs.FanOutOneBlockAsyncDFSOutputSaslHelper.EncryptHandler
allocateBuffer()
- Method in class org.apache.hadoop.hbase.io.hfile.HFileBlock
@@ -3817,7 +3817,7 @@
AsyncAdminRequestRetryingCallerT - Class in
org.apache.hadoop.hbase.client
-AsyncAdminRequestRetryingCaller(HashedWheelTimer,
AsyncConnectionImpl, long, int, long, long, int, ServerName,
AsyncAdminRequestRetryingCaller.CallableT) - Constructor for
class org.apache.hadoop.hbase.client.AsyncAdminRequestRetryingCaller
+AsyncAdminRequestRetryingCaller(HashedWheelTimer,
AsyncConnectionImpl, long, int, long, long, int, ServerName,
AsyncAdminRequestRetryingCaller.CallableT) - Constructor for
class org.apache.hadoop.hbase.client.AsyncAdminRequestRetryingCaller
AsyncAdminRequestRetryingCaller.CallableT -
Interface in org.apache.hadoop.hbase.client
@@ -3834,7 +3834,7 @@
Retry caller for batch.
-AsyncBatchRpcRetryingCaller(HashedWheelTimer,
AsyncConnectionImpl, TableName, List? extends Row, long, int, long,
long, int) - Constructor for class org.apache.hadoop.hbase.client.AsyncBatchRpcRetryingCaller
+AsyncBatchRpcRetryingCaller(HashedWheelTimer,
AsyncConnectionImpl, TableName, List? extends Row, long, int, long,
long, int) - Constructor for class org.apache.hadoop.hbase.client.AsyncBatchRpcRetryingCaller
AsyncBatchRpcRetryingCaller.RegionRequest -
Class in org.apache.hadoop.hbase.client
@@ -3896,7 +3896,7 @@
An asynchronous implementation of FSWAL.
-AsyncFSWAL(FileSystem,
Path, String, String, Configuration, ListWALActionsListener, boolean,
String, String, EventLoop, Class? extends Channel) -
Constructor for class org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL
+AsyncFSWAL(FileSystem,
Path, String, String, Configuration, ListWALActionsListener, boolean,
String, String, EventLoop, Class? extends Channel) -
Constructor for class org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL
AsyncFSWALProvider - Class in org.apache.hadoop.hbase.wal
@@ -3918,7 +3918,7 @@
Retry caller for a request call to master.
-AsyncMasterRequestRpcRetryingCaller(HashedWheelTimer,
AsyncConnectionImpl, AsyncMasterRequestRpcRetryingCaller.CallableT,
long, int, long, long, int) - Constructor for class
org.apache.hadoop.hbase.client.AsyncMasterRequestRpcRetryingCaller
+AsyncMasterRequestRpcRetryingCaller(HashedWheelTimer,
AsyncConnectionImpl, AsyncMasterRequestRpcRetryingCaller.CallableT,
long, int, long, long, int) - Constructor for class
org.apache.hadoop.hbase.client.AsyncMasterRequestRpcRetryingCaller
AsyncMasterRequestRpcRetryingCaller.CallableT - Interface in org.apache.hadoop.hbase.client
@@ -3983,7 +3983,7 @@
AsyncWriter for protobuf-based WAL.
-AsyncProtobufLogWriter(EventLoop,
Class? extends Channel) - Constructor for class
org.apache.hadoop.hbase.regionserver.wal.AsyncProtobufLogWriter
+AsyncProtobufLogWriter(EventLoop,
Class? extends Channel) - Constructor for class
org.apache.hadoop.hbase.regionserver.wal.AsyncProtobufLogWriter
AsyncProtobufLogWriter.OutputStreamWrapper -
Class in org.apache.hadoop.hbase.regionserver.wal
@@ -3991,7 +3991,7 @@
The asynchronous region locator.
-AsyncRegionLocator(AsyncConnectionImpl,
HashedWheelTimer) - Constructor for class
org.apache.hadoop.hbase.client.AsyncRegionLocator
+AsyncRegionLocator(AsyncConnectionImpl,
HashedWheelTimer) - Constructor for class
org.apache.hadoop.hbase.client.AsyncRegionLocator
AsyncRegistry - Interface in org.apache.hadoop.hbase.client
@@ -4034,13 +4034,13 @@
AsyncRpcRetryingCallerT - Class in org.apache.hadoop.hbase.client
-AsyncRpcRetryingCaller(HashedWheelTimer,
AsyncConnectionImpl, long, int, long, long, int) - Constructor for
class org.apache.hadoop.hbase.client.AsyncRpcRetryingCaller
+AsyncRpcRetryingCaller(HashedWheelTimer,
AsyncConnectionImpl, long, int, long, long, int) - Constructor for
class org.apache.hadoop.hbase.client.AsyncRpcRetryingCaller
AsyncRpcRetryingCallerFactory - Class in org.apache.hadoop.hbase.client
Factory to create an AsyncRpcRetryCaller.
-AsyncRpcRetryingCallerFactory(AsyncConnectionImpl,
HashedWheelTimer) - Constructor for class
org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory
+AsyncRpcRetryingCallerFactory(AsyncConnectionImpl,
HashedWheelTimer) - Constructor for class
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8bae1c8a/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.Command.html
--
diff --git
a/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.Command.html
b/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.Command.html
index 11408eb..f18d891 100644
--- a/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.Command.html
+++ b/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.Command.html
@@ -118,7 +118,7 @@ var activeTableTab = "activeTableTab";
Direct Known Subclasses:
-BackupCommands.BackupSetCommand, BackupCommands.CancelCommand, BackupCommands.CreateCommand, BackupCommands.DeleteCommand, BackupCommands.DescribeCommand, BackupCommands.HelpCommand, BackupCommands.HistoryCommand, BackupCommands.ProgressCommand, BackupCommands.RepairCommand
+BackupCommands.BackupSetCommand, BackupCommands.CancelCommand, BackupCommands.CreateCommand, BackupCommands.DeleteCommand, BackupCommands.DescribeCommand, BackupCommands.HelpCommand, BackupCommands.HistoryCommand, BackupCommands.MergeCommand, BackupCommands.ProgressCommand, BackupCommands.RepairCommand
Enclosing class:
@@ -126,7 +126,7 @@ var activeTableTab = "activeTableTab";
-public abstract static class BackupCommands.Command
+public abstract static class BackupCommands.Command
extends org.apache.hadoop.conf.Configured
@@ -201,9 +201,8 @@ extends org.apache.hadoop.conf.Configured
protected boolean
requiresConsistentState()
-Command requires consistent state of a backup system
- Backup system may become inconsistent because of an abnormal
- termination of a backup session or delete command
+Command requires consistent state of a backup system Backup
system may become inconsistent
+ because of an abnormal termination of a backup session or delete command
@@ -247,7 +246,7 @@ extends org.apache.hadoop.conf.Configured
cmdline
-org.apache.commons.cli.CommandLine cmdline
+org.apache.commons.cli.CommandLine cmdline
@@ -256,7 +255,7 @@ extends org.apache.hadoop.conf.Configured
conn
-Connection conn
+Connection conn
@@ -273,7 +272,7 @@ extends org.apache.hadoop.conf.Configured
Command
-Command(org.apache.hadoop.conf.Configurationconf)
+Command(org.apache.hadoop.conf.Configurationconf)
@@ -290,7 +289,7 @@ extends org.apache.hadoop.conf.Configured
execute
-publicvoidexecute()
+publicvoidexecute()
throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true;
title="class or interface in java.io">IOException
Throws:
@@ -304,7 +303,7 @@ extends org.apache.hadoop.conf.Configured
finish
-publicvoidfinish()
+publicvoidfinish()
throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true;
title="class or interface in java.io">IOException
Throws:
@@ -318,7 +317,7 @@ extends org.apache.hadoop.conf.Configured
printUsage
-protected abstractvoidprintUsage()
+protected abstractvoidprintUsage()
@@ -327,7 +326,7 @@ extends org.apache.hadoop.conf.Configured
requiresNoActiveSession
-protectedbooleanrequiresNoActiveSession()
+protectedbooleanrequiresNoActiveSession()
The command can't be run if active backup session is in
progress
Returns:
@@ -341,10 +340,9 @@ extends org.apache.hadoop.conf.Configured
requiresConsistentState
-protectedbooleanrequiresConsistentState()
-Command requires consistent state of a backup system
- Backup system may become inconsistent because of an abnormal
- termination of a backup session or delete command
+protectedbooleanrequiresConsistentState()
+Command requires consistent state of a backup system Backup
system may become inconsistent
+ because of an abnormal termination of a backup session or delete command
Returns:
true, if yes
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8bae1c8a/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.CreateCommand.html
--
diff --git
a/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.CreateCommand.html
b/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.CreateCommand.html
index 036dad8..df01402 100644
---
a/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.CreateCommand.html
+++
b/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.CreateCommand.html
@@ -127,7 +127,7 @@ var activeTableTab = "activeTableTab";
-public static class BackupCommands.CreateCommand
+public static class BackupCommands.CreateCommand
extends BackupCommands.Command
@@ -196,9 +196,8 @@ extends
protected boolean
requiresConsistentState()
-Command requires consistent state of a backup system
- Backup system may become inconsistent because of an abnormal
- termination of a backup session or delete command
+Command requires consistent state of
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8bae1c8a/devapidocs/org/apache/hadoop/hbase/ClusterStatus.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/ClusterStatus.html
b/devapidocs/org/apache/hadoop/hbase/ClusterStatus.html
index 4748516..6c58afa 100644
--- a/devapidocs/org/apache/hadoop/hbase/ClusterStatus.html
+++ b/devapidocs/org/apache/hadoop/hbase/ClusterStatus.html
@@ -18,8 +18,8 @@
catch(err) {
}
//-->
-var methods =
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":42,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10};
-var tabs = {65535:["t0","All Methods"],2:["t2","Instance
Methods"],8:["t4","Concrete Methods"],32:["t6","Deprecated Methods"]};
+var methods =
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":42,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":9,"i24":10};
+var tabs = {65535:["t0","All Methods"],1:["t1","Static
Methods"],2:["t2","Instance Methods"],8:["t4","Concrete
Methods"],32:["t6","Deprecated Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
var tableTab = "tableTab";
@@ -50,7 +50,7 @@ var activeTableTab = "activeTableTab";
PrevClass
-NextClass
+NextClass
Frames
@@ -74,7 +74,7 @@ var activeTableTab = "activeTableTab";
Summary:
-Nested|
+Nested|
Field|
Constr|
Method
@@ -119,7 +119,7 @@ var activeTableTab = "activeTableTab";
@InterfaceAudience.Public
-public class ClusterStatus
+public class ClusterStatus
extends org.apache.hadoop.io.VersionedWritable
Status information on the HBase cluster.
@@ -136,13 +136,62 @@ extends org.apache.hadoop.io.VersionedWritable
per server and per region.
Regions in transition at master
The unique cluster ID
-
+
+ ClusterStatus.Options provides a
way to filter out infos which unwanted.
+ The following codes will retrieve all the cluster information.
+
+
+ // Original version still works
+ Admin admin = connection.getAdmin();
+ ClusterStatus status = admin.getClusterStatus();
+ // or below, a new version which has the same effects
+ ClusterStatus status = admin.getClusterStatus(Options.defaultOptions());
+
+
+ If information about dead servers and master coprocessors are unwanted,
+ then codes in the following way:
+
+
+ Admin admin = connection.getAdmin();
+ ClusterStatus status = admin.getClusterStatus(
+Options.defaultOptions()
+ .excludeDeadServers()
+ .excludeMasterCoprocessors());
+
+
+
+
+
+
+
+Nested Class Summary
+
+Nested Classes
+
+Modifier and Type
+Class and Description
+
+
+static class
+ClusterStatus.Builder
+Builder for construct a ClusterStatus.
+
+
+
+static class
+ClusterStatus.Options
+Options provides a way to filter out unwanted
information.
+
+
+
+
+
@@ -220,7 +269,12 @@ extends org.apache.hadoop.io.VersionedWritable
http://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true;
title="class or interface in java.util">CollectionServerNamebackupMasters,
http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true;
title="class or interface in java.util">ListRegionStaterit,
http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String[]masterCoprocessors,
- http://docs.oracle.com/javase/8/docs/api/java/lang/Boolean.html?is-external=true;
title="class or interface in
java.lang">BooleanbalancerOn)
+ http://docs.oracle.com/javase/8/docs/api/java/lang/Boolean.html?is-external=true;
title="class or interface in java.lang">BooleanbalancerOn)
+Deprecated.
+As of release 2.0.0, this
will be removed in HBase 3.0.0
+ (https://issues.apache.org/jira/browse/HBASE-15511;>HBASE-15511).
+
+
@@ -232,7 +286,7 @@ extends org.apache.hadoop.io.VersionedWritable
Method Summary
-All MethodsInstance MethodsConcrete MethodsDeprecated Methods
+All MethodsStatic MethodsInstance MethodsConcrete MethodsDeprecated Methods
Modifier and Type
Method and Description
@@ -338,6 +392,10 @@ extends org.apache.hadoop.io.VersionedWritable
isBalancerOn()
+static ClusterStatus.Builder
+newBuilder()
+
+
http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">String
toString()
@@ -376,7 +434,7 @@ extends org.apache.hadoop.io.VersionedWritable
VERSION
-private static finalbyte VERSION
+private static finalbyte VERSION
Version for object serialization. Incremented for changes
in serialized
representation.
@@ -397,7 +455,7 @@ extends org.apache.hadoop.io.VersionedWritable
hbaseVersion
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8bae1c8a/apidocs/org/apache/hadoop/hbase/client/AsyncAdmin.html
--
diff --git a/apidocs/org/apache/hadoop/hbase/client/AsyncAdmin.html
b/apidocs/org/apache/hadoop/hbase/client/AsyncAdmin.html
index e5db1b0..efbf566 100644
--- a/apidocs/org/apache/hadoop/hbase/client/AsyncAdmin.html
+++ b/apidocs/org/apache/hadoop/hbase/client/AsyncAdmin.html
@@ -18,7 +18,7 @@
catch(err) {
}
//-->
-var methods =
{"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":18,"i6":6,"i7":6,"i8":6,"i9":38,"i10":18,"i11":6,"i12":18,"i13":6,"i14":6,"i15":6,"i16":6,"i17":6,"i18":18,"i19":6,"i20":6,"i21":6,"i22":6,"i23":6,"i24":18,"i25":6,"i26":6,"i27":6,"i28":6,"i29":6,"i30":6,"i31":6,"i32":6,"i33":6,"i34":6,"i35":6,"i36":6,"i37":6,"i38":6,"i39":6,"i40":18,"i41":6,"i42":6,"i43":6,"i44":6,"i45":6,"i46":18,"i47":6,"i48":6,"i49":6,"i50":18,"i51":6,"i52":18,"i53":6,"i54":6,"i55":6,"i56":6,"i57":6,"i58":6,"i59":6,"i60":6,"i61":6,"i62":6,"i63":6,"i64":6,"i65":6,"i66":18,"i67":6,"i68":6,"i69":6,"i70":6,"i71":6,"i72":6,"i73":6,"i74":6,"i75":18,"i76":6,"i77":18,"i78":6,"i79":18,"i80":6,"i81":18,"i82":6,"i83":6,"i84":18,"i85":6,"i86":18,"i87":6,"i88":6,"i89":6,"i90":6,"i91":6,"i92":6,"i93":6,"i94":6,"i95":6,"i96":6,"i97":6,"i98":6,"i99":6,"i100":6,"i101":6,"i102":6,"i103":6,"i104":6,"i105":6,"i106":6,"i107":6,"i108":6,"i109":6,"i110":6,"i111":6,"i112":18,"i113":18,"i114":6,"i115":6,"i116":18,"i117":6,"i118":6,"
i119":6,"i120":6,"i121":6,"i122":6,"i123":6,"i124":6,"i125":6};
+var methods =
{"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":18,"i6":6,"i7":6,"i8":6,"i9":38,"i10":18,"i11":6,"i12":18,"i13":6,"i14":6,"i15":6,"i16":6,"i17":6,"i18":18,"i19":6,"i20":6,"i21":6,"i22":6,"i23":6,"i24":18,"i25":6,"i26":6,"i27":6,"i28":6,"i29":6,"i30":6,"i31":6,"i32":6,"i33":6,"i34":6,"i35":6,"i36":6,"i37":6,"i38":6,"i39":6,"i40":18,"i41":6,"i42":6,"i43":6,"i44":6,"i45":6,"i46":6,"i47":18,"i48":6,"i49":6,"i50":6,"i51":18,"i52":6,"i53":18,"i54":6,"i55":6,"i56":6,"i57":6,"i58":6,"i59":6,"i60":6,"i61":6,"i62":6,"i63":6,"i64":6,"i65":6,"i66":6,"i67":18,"i68":6,"i69":6,"i70":6,"i71":6,"i72":6,"i73":6,"i74":6,"i75":6,"i76":18,"i77":6,"i78":18,"i79":6,"i80":18,"i81":6,"i82":18,"i83":6,"i84":6,"i85":18,"i86":6,"i87":18,"i88":6,"i89":6,"i90":6,"i91":6,"i92":6,"i93":6,"i94":6,"i95":6,"i96":6,"i97":6,"i98":6,"i99":6,"i100":6,"i101":6,"i102":6,"i103":6,"i104":6,"i105":6,"i106":6,"i107":6,"i108":6,"i109":6,"i110":6,"i111":6,"i112":6,"i113":18,"i114":18,"i115":6,"i116":6,"i117":18,"i118":6,"
i119":6,"i120":6,"i121":6,"i122":6,"i123":6,"i124":6,"i125":6,"i126":6};
var tabs = {65535:["t0","All Methods"],2:["t2","Instance
Methods"],4:["t3","Abstract Methods"],16:["t5","Default
Methods"],32:["t6","Deprecated Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
@@ -102,7 +102,7 @@ var activeTableTab = "activeTableTab";
@InterfaceAudience.Public
-public interface AsyncAdmin
+public interface AsyncAdmin
The asynchronous administrative API for HBase.
This feature is still under development, so marked as IA.Private. Will change
to public when
@@ -398,127 +398,131 @@ public interface getClusterStatus()
+http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true;
title="class or interface in java.util.concurrent">CompletableFutureClusterStatus
+getClusterStatus(org.apache.hadoop.hbase.ClusterStatus.Optionsoptions)
+
+
http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true;
title="class or interface in java.util.concurrent">CompletableFutureCompactionState
getCompactionState(TableNametableName)
Get the current compaction state of a table.
-
+
http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true;
title="class or interface in java.util.concurrent">CompletableFutureCompactionState
getCompactionStateForRegion(byte[]regionName)
Get the current compaction state of region.
-
+
http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true;
title="class or interface in java.util.concurrent">CompletableFuturehttp://docs.oracle.com/javase/8/docs/api/java/util/Optional.html?is-external=true;
title="class or interface in java.util">Optionalhttp://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true;
title="class or interface in java.lang">Long
getLastMajorCompactionTimestamp(TableNametableName)
Get the timestamp of the last major compaction for the
passed table.
-
+
http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true;
title="class or interface in java.util.concurrent">CompletableFuturehttp://docs.oracle.com/javase/8/docs/api/java/util/Optional.html?is-external=true;
title="class or interface in
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8bae1c8a/devapidocs/org/apache/hadoop/hbase/client/AsyncAdmin.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/client/AsyncAdmin.html
b/devapidocs/org/apache/hadoop/hbase/client/AsyncAdmin.html
index eae7b36..8935670 100644
--- a/devapidocs/org/apache/hadoop/hbase/client/AsyncAdmin.html
+++ b/devapidocs/org/apache/hadoop/hbase/client/AsyncAdmin.html
@@ -18,7 +18,7 @@
catch(err) {
}
//-->
-var methods =
{"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":18,"i6":6,"i7":6,"i8":6,"i9":38,"i10":18,"i11":6,"i12":18,"i13":6,"i14":6,"i15":6,"i16":6,"i17":6,"i18":18,"i19":6,"i20":6,"i21":6,"i22":6,"i23":6,"i24":18,"i25":6,"i26":6,"i27":6,"i28":6,"i29":6,"i30":6,"i31":6,"i32":6,"i33":6,"i34":6,"i35":6,"i36":6,"i37":6,"i38":6,"i39":6,"i40":18,"i41":6,"i42":6,"i43":6,"i44":6,"i45":6,"i46":18,"i47":6,"i48":6,"i49":6,"i50":18,"i51":6,"i52":18,"i53":6,"i54":6,"i55":6,"i56":6,"i57":6,"i58":6,"i59":6,"i60":6,"i61":6,"i62":6,"i63":6,"i64":6,"i65":6,"i66":18,"i67":6,"i68":6,"i69":6,"i70":6,"i71":6,"i72":6,"i73":6,"i74":6,"i75":18,"i76":6,"i77":18,"i78":6,"i79":18,"i80":6,"i81":18,"i82":6,"i83":6,"i84":18,"i85":6,"i86":18,"i87":6,"i88":6,"i89":6,"i90":6,"i91":6,"i92":6,"i93":6,"i94":6,"i95":6,"i96":6,"i97":6,"i98":6,"i99":6,"i100":6,"i101":6,"i102":6,"i103":6,"i104":6,"i105":6,"i106":6,"i107":6,"i108":6,"i109":6,"i110":6,"i111":6,"i112":18,"i113":18,"i114":6,"i115":6,"i116":18,"i117":6,"i118":6,"
i119":6,"i120":6,"i121":6,"i122":6,"i123":6,"i124":6,"i125":6};
+var methods =
{"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":18,"i6":6,"i7":6,"i8":6,"i9":38,"i10":18,"i11":6,"i12":18,"i13":6,"i14":6,"i15":6,"i16":6,"i17":6,"i18":18,"i19":6,"i20":6,"i21":6,"i22":6,"i23":6,"i24":18,"i25":6,"i26":6,"i27":6,"i28":6,"i29":6,"i30":6,"i31":6,"i32":6,"i33":6,"i34":6,"i35":6,"i36":6,"i37":6,"i38":6,"i39":6,"i40":18,"i41":6,"i42":6,"i43":6,"i44":6,"i45":6,"i46":6,"i47":18,"i48":6,"i49":6,"i50":6,"i51":18,"i52":6,"i53":18,"i54":6,"i55":6,"i56":6,"i57":6,"i58":6,"i59":6,"i60":6,"i61":6,"i62":6,"i63":6,"i64":6,"i65":6,"i66":6,"i67":18,"i68":6,"i69":6,"i70":6,"i71":6,"i72":6,"i73":6,"i74":6,"i75":6,"i76":18,"i77":6,"i78":18,"i79":6,"i80":18,"i81":6,"i82":18,"i83":6,"i84":6,"i85":18,"i86":6,"i87":18,"i88":6,"i89":6,"i90":6,"i91":6,"i92":6,"i93":6,"i94":6,"i95":6,"i96":6,"i97":6,"i98":6,"i99":6,"i100":6,"i101":6,"i102":6,"i103":6,"i104":6,"i105":6,"i106":6,"i107":6,"i108":6,"i109":6,"i110":6,"i111":6,"i112":6,"i113":18,"i114":18,"i115":6,"i116":6,"i117":18,"i118":6,"
i119":6,"i120":6,"i121":6,"i122":6,"i123":6,"i124":6,"i125":6,"i126":6};
var tabs = {65535:["t0","All Methods"],2:["t2","Instance
Methods"],4:["t3","Abstract Methods"],16:["t5","Default
Methods"],32:["t6","Deprecated Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
@@ -106,7 +106,7 @@ var activeTableTab = "activeTableTab";
@InterfaceAudience.Public
-public interface AsyncAdmin
+public interface AsyncAdmin
The asynchronous administrative API for HBase.
This feature is still under development, so marked as IA.Private. Will change
to public when
@@ -402,127 +402,131 @@ public interface getClusterStatus()
+http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true;
title="class or interface in java.util.concurrent">CompletableFutureClusterStatus
+getClusterStatus(ClusterStatus.Optionsoptions)
+
+
http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true;
title="class or interface in java.util.concurrent">CompletableFutureCompactionState
getCompactionState(TableNametableName)
Get the current compaction state of a table.
-
+
http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true;
title="class or interface in java.util.concurrent">CompletableFutureCompactionState
getCompactionStateForRegion(byte[]regionName)
Get the current compaction state of region.
-
+
http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true;
title="class or interface in java.util.concurrent">CompletableFuturehttp://docs.oracle.com/javase/8/docs/api/java/util/Optional.html?is-external=true;
title="class or interface in java.util">Optionalhttp://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true;
title="class or interface in java.lang">Long
getLastMajorCompactionTimestamp(TableNametableName)
Get the timestamp of the last major compaction for the
passed table.
-
+
http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true;
title="class or interface in java.util.concurrent">CompletableFuturehttp://docs.oracle.com/javase/8/docs/api/java/util/Optional.html?is-external=true;
title="class or interface in
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8bae1c8a/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupManager.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupManager.html
b/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupManager.html
index ec5a05d..04d6eb3 100644
--- a/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupManager.html
+++ b/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupManager.html
@@ -590,7 +590,7 @@ implements http://docs.oracle.com/javase/8/docs/api/java/io/Closeable.h
getOngoingBackupId
-privatehttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">StringgetOngoingBackupId()
+privatehttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface in java.lang">StringgetOngoingBackupId()
throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true;
title="class or interface in java.io">IOException
Check if any ongoing backup. Currently, we only reply on
checking status in backup system
table. We need to consider to handle the case of orphan records in the
future. Otherwise, all
@@ -609,7 +609,7 @@ implements http://docs.oracle.com/javase/8/docs/api/java/io/Closeable.h
initialize
-publicvoidinitialize()
+publicvoidinitialize()
throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true;
title="class or interface in java.io">IOException
Start the backup manager service.
@@ -624,7 +624,7 @@ implements http://docs.oracle.com/javase/8/docs/api/java/io/Closeable.h
setBackupInfo
-publicvoidsetBackupInfo(BackupInfobackupInfo)
+publicvoidsetBackupInfo(BackupInfobackupInfo)
@@ -633,7 +633,7 @@ implements http://docs.oracle.com/javase/8/docs/api/java/io/Closeable.h
getAncestors
-publichttp://docs.oracle.com/javase/8/docs/api/java/util/ArrayList.html?is-external=true;
title="class or interface in java.util">ArrayListBackupManifest.BackupImagegetAncestors(BackupInfobackupInfo)
+publichttp://docs.oracle.com/javase/8/docs/api/java/util/ArrayList.html?is-external=true;
title="class or interface in java.util">ArrayListBackupManifest.BackupImagegetAncestors(BackupInfobackupInfo)
throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true;
title="class or interface in java.io">IOException,
BackupException
Get direct ancestors of the current backup.
@@ -654,7 +654,7 @@ implements http://docs.oracle.com/javase/8/docs/api/java/io/Closeable.h
getAncestors
-publichttp://docs.oracle.com/javase/8/docs/api/java/util/ArrayList.html?is-external=true;
title="class or interface in java.util">ArrayListBackupManifest.BackupImagegetAncestors(BackupInfobackupInfo,
+publichttp://docs.oracle.com/javase/8/docs/api/java/util/ArrayList.html?is-external=true;
title="class or interface in java.util">ArrayListBackupManifest.BackupImagegetAncestors(BackupInfobackupInfo,
TableNametable)
throws BackupException,
http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true;
title="class or interface in java.io">IOException
@@ -677,7 +677,7 @@ implements http://docs.oracle.com/javase/8/docs/api/java/io/Closeable.h
updateBackupInfo
-publicvoidupdateBackupInfo(BackupInfocontext)
+publicvoidupdateBackupInfo(BackupInfocontext)
throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true;
title="class or interface in java.io">IOException
Updates status (state) of a backup session in a persistent
store
@@ -694,7 +694,7 @@ implements http://docs.oracle.com/javase/8/docs/api/java/io/Closeable.h
startBackupSession
-publicvoidstartBackupSession()
+publicvoidstartBackupSession()
throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true;
title="class or interface in java.io">IOException
Starts new backup session
@@ -709,7 +709,7 @@ implements http://docs.oracle.com/javase/8/docs/api/java/io/Closeable.h
finishBackupSession
-publicvoidfinishBackupSession()
+publicvoidfinishBackupSession()
throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true;
title="class or interface in java.io">IOException
Finishes active backup session
@@ -724,7 +724,7 @@ implements http://docs.oracle.com/javase/8/docs/api/java/io/Closeable.h
readBackupStartCode
-publichttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
title="class or interface
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8bae1c8a/devapidocs/org/apache/hadoop/hbase/classification/class-use/InterfaceAudience.Private.html
--
diff --git
a/devapidocs/org/apache/hadoop/hbase/classification/class-use/InterfaceAudience.Private.html
b/devapidocs/org/apache/hadoop/hbase/classification/class-use/InterfaceAudience.Private.html
index 9459d48..f11508b 100644
---
a/devapidocs/org/apache/hadoop/hbase/classification/class-use/InterfaceAudience.Private.html
+++
b/devapidocs/org/apache/hadoop/hbase/classification/class-use/InterfaceAudience.Private.html
@@ -1199,73 +1199,79 @@ service.
+interface
+BackupMergeJob
+Backup merge operation job interface.
+
+
+
class
BackupRequest
POJO class for backup request
-
+
interface
BackupRestoreConstants
BackupRestoreConstants holds a bunch of HBase Backup and
Restore constants
-
+
class
BackupRestoreFactory
Factory implementation for backup/restore related jobs
-
+
class
BackupTableInfo
Backup related information encapsulated for a table.
-
+
class
BackupType
-
+
class
FailedArchiveException
Exception indicating that some files in the requested set
could not be archived.
-
+
class
HBackupFileSystem
View to an on-disk Backup Image FileSytem Provides the set
of methods necessary to interact with
the on-disk Backup Image data.
-
+
class
HFileArchiver
Utility class to handle the removal of HFiles (or the
respective StoreFiles)
for a HRegion from the FileSystem.
-
+
(package private) class
LogUtils
Utility class for disabling Zk and client logging
-
+
class
RestoreDriver
Command-line entry point for restore operation
-
+
interface
RestoreJob
Restore operation job interface Concrete implementation is
provided by backup provider, see
BackupRestoreFactory
-
+
class
RestoreRequest
POJO class for restore request
@@ -1401,25 +1407,31 @@ service.
class
-HFileSplitterJob
-A tool to split HFiles into new region boundaries as a
MapReduce job.
+MapReduceBackupCopyJob
+Map-Reduce implementation of BackupCopyJob.
class
-MapReduceBackupCopyJob
-Map-Reduce implementation of BackupCopyJob.
+MapReduceBackupMergeJob
+MapReduce implementation of BackupMergeJob
+ Must be initialized with configuration of a backup destination cluster
class
+MapReduceHFileSplitterJob
+A tool to split HFiles into new region boundaries as a
MapReduce job.
+
+
+
+class
MapReduceRestoreJob
MapReduce implementation of RestoreJob
- For full backup restore, it runs HFileSplitterJob job
and creates
+ For backup restore, it runs MapReduceHFileSplitterJob
job and creates
HFiles which are aligned with a region boundaries of a table being
- restored, for incremental backup restore it runs WALPlayer in
- bulk load mode (creates HFiles from WAL edits).
+ restored.
@@ -1916,110 +1928,116 @@ service.
+class
+ImmutableHTableDescriptor
+Deprecated.
+
+
+
(package private) class
MasterCoprocessorRpcChannelImpl
The implementation of a master based coprocessor rpc
channel.
-
+
class
MetaCache
A cache implementation for region locations from meta.
-
+
class
MetricsConnection
This class is for maintaining the various connection
statistics and publishing them through
the metrics interfaces.
-
+
class
MultiAction
Container for Actions (i.e.
-
+
class
MultiResponse
A container for Result objects, grouped by regionName.
-
+
(package private) class
MultiServerCallable
Callable that handles the multi method call
going against a single
regionserver; i.e.
-
+
class
NoncedRegionServerCallableT
Implementations make an rpc call against a RegionService
via a protobuf Service.
-
+
interface
NonceGenerator
NonceGenerator interface.
-
+
(package private) class
NoOpRetryableCallerInterceptor
Class that acts as a NoOpInterceptor.
-
+
(package private) class
NoOpRetryingInterceptorContext
-
+
class
PackagePrivateFieldAccessor
A helper class used to access the package private field in
o.a.h.h.client package.
-
+
class
PerClientRandomNonceGenerator
NonceGenerator implementation that uses client ID hash +
random int as nonce group, and random
numbers as nonces.
-
+
(package private) class
PreemptiveFastFailInterceptor
The concrete RetryingCallerInterceptor
class that implements the preemptive fast fail
feature.
-
+
class
QuotaStatusCalls
Client class to wrap RPCs to HBase servers for space quota
status information.
-
+
class
RawAsyncHBaseAdmin
The implementation of AsyncAdmin.
-
+
(package private) class
RawAsyncTableImpl
The implementation of RawAsyncTable.
-
+
class
RegionAdminServiceCallableT
Similar to RegionServerCallable but for the AdminService
interface.
-
+
(package private) class
RegionCoprocessorRpcChannel
Provides clients with an RPC connection to call Coprocessor
Endpoint
@@ -2027,93
Repository: hbase-site
Updated Branches:
refs/heads/asf-site c70834a52 -> 8bae1c8a1
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/8bae1c8a/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.html
b/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.html
index 5ef3b38..e93b0e3 100644
--- a/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.html
+++ b/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.html
@@ -1299,7 +1299,7 @@ implements
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.Master
getCompletedSnapshots
-publicorg.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetCompletedSnapshotsResponsegetCompletedSnapshots(org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcControllercontroller,
+publicorg.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetCompletedSnapshotsResponsegetCompletedSnapshots(org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcControllercontroller,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetCompletedSnapshotsRequestrequest)
throws
org.apache.hadoop.hbase.shaded.com.google.protobuf.ServiceException
List the currently available/stored snapshots. Any
in-progress snapshots are ignored
@@ -1317,7 +1317,7 @@ implements
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.Master
getNamespaceDescriptor
-publicorg.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetNamespaceDescriptorResponsegetNamespaceDescriptor(org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcControllercontroller,
+publicorg.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetNamespaceDescriptorResponsegetNamespaceDescriptor(org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcControllercontroller,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetNamespaceDescriptorRequestrequest)
throws
org.apache.hadoop.hbase.shaded.com.google.protobuf.ServiceException
@@ -1334,7 +1334,7 @@ implements
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.Master
getSchemaAlterStatus
-publicorg.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetSchemaAlterStatusResponsegetSchemaAlterStatus(org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcControllercontroller,
+publicorg.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetSchemaAlterStatusResponsegetSchemaAlterStatus(org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcControllercontroller,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetSchemaAlterStatusRequestreq)
throws
org.apache.hadoop.hbase.shaded.com.google.protobuf.ServiceException
Get the number of regions of the table that have been
updated by the alter.
@@ -1356,7 +1356,7 @@ implements
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.Master
getTableDescriptors
-publicorg.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetTableDescriptorsResponsegetTableDescriptors(org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcControllerc,
+publicorg.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetTableDescriptorsResponsegetTableDescriptors(org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcControllerc,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetTableDescriptorsRequestreq)
throws
org.apache.hadoop.hbase.shaded.com.google.protobuf.ServiceException
Get list of TableDescriptors for requested tables.
@@ -1380,7 +1380,7 @@ implements
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.Master
getTableNames
-publicorg.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.GetTableNamesResponsegetTableNames(org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcControllercontroller,