hbase git commit: HBASE-18884 (addendum) Add more javadoc comment. Coprocessor Design Improvements follow up of HBASE-17732.
Repository: hbase Updated Branches: refs/heads/branch-2 759110c22 -> 4579bba48 HBASE-18884 (addendum) Add more javadoc comment. Coprocessor Design Improvements follow up of HBASE-17732. Change-Id: Id1a9e508cc04612b1e79e6cfa7e39b7755598be3 Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/4579bba4 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/4579bba4 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/4579bba4 Branch: refs/heads/branch-2 Commit: 4579bba48652cf0c25245761d315d71347298104 Parents: 759110c Author: Apekshit SharmaAuthored: Fri Sep 29 17:24:10 2017 -0700 Committer: Apekshit Sharma Committed: Fri Sep 29 17:32:41 2017 -0700 -- .../src/main/java/org/apache/hadoop/hbase/Coprocessor.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/4579bba4/hbase-client/src/main/java/org/apache/hadoop/hbase/Coprocessor.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/Coprocessor.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/Coprocessor.java index 422e064..c0d9b60 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/Coprocessor.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/Coprocessor.java @@ -96,7 +96,9 @@ public interface Coprocessor { default void stop(CoprocessorEnvironment env) throws IOException {} /** - * Coprocessor endpoints providing protobuf services should implement this interface. + * Coprocessor endpoints providing protobuf services should override this method. + * @return Iterable of {@link Service}s or empty collection. Implementations should never + * return null. */ default Iterable getServices() { return Collections.EMPTY_SET;
hbase git commit: HBASE-18884 (addendum) Add more javadoc comment. Coprocessor Design Improvements follow up of HBASE-17732.
Repository: hbase Updated Branches: refs/heads/master c835dcc7e -> cacf3f583 HBASE-18884 (addendum) Add more javadoc comment. Coprocessor Design Improvements follow up of HBASE-17732. Change-Id: Id1a9e508cc04612b1e79e6cfa7e39b7755598be3 Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/cacf3f58 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/cacf3f58 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/cacf3f58 Branch: refs/heads/master Commit: cacf3f58356df41fe15e8375f9b633d3db16f8c6 Parents: c835dcc Author: Apekshit SharmaAuthored: Fri Sep 29 17:24:10 2017 -0700 Committer: Apekshit Sharma Committed: Fri Sep 29 17:32:11 2017 -0700 -- .../src/main/java/org/apache/hadoop/hbase/Coprocessor.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/cacf3f58/hbase-client/src/main/java/org/apache/hadoop/hbase/Coprocessor.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/Coprocessor.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/Coprocessor.java index 422e064..c0d9b60 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/Coprocessor.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/Coprocessor.java @@ -96,7 +96,9 @@ public interface Coprocessor { default void stop(CoprocessorEnvironment env) throws IOException {} /** - * Coprocessor endpoints providing protobuf services should implement this interface. + * Coprocessor endpoints providing protobuf services should override this method. + * @return Iterable of {@link Service}s or empty collection. Implementations should never + * return null. */ default Iterable getServices() { return Collections.EMPTY_SET;
[2/4] hbase git commit: HBASE-18559 Add histogram to MetricsConnection to track concurrent calls per server
HBASE-18559 Add histogram to MetricsConnection to track concurrent calls per server Signed-off-by: Andrew PurtellProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/66d348a3 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/66d348a3 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/66d348a3 Branch: refs/heads/branch-1.4 Commit: 66d348a3f88ae8092a1e6836a7978952a0cac6a3 Parents: 790d006 Author: Robert Yokota Authored: Thu Aug 10 14:13:04 2017 -0700 Committer: Andrew Purtell Committed: Fri Sep 29 17:12:23 2017 -0700 -- .../hadoop/hbase/client/MetricsConnection.java | 16 .../apache/hadoop/hbase/ipc/AbstractRpcClient.java | 1 + 2 files changed, 17 insertions(+) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/66d348a3/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java index 7180ac2..6328d7f 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java @@ -71,6 +71,7 @@ public class MetricsConnection implements StatisticTrackable { private long responseSizeBytes = 0; private long startTime = 0; private long callTimeMs = 0; +private int concurrentCallsPerServer = 0; public long getRequestSizeBytes() { return requestSizeBytes; @@ -103,6 +104,14 @@ public class MetricsConnection implements StatisticTrackable { public void setCallTimeMs(long callTimeMs) { this.callTimeMs = callTimeMs; } + +public int getConcurrentCallsPerServer() { + return concurrentCallsPerServer; +} + +public void setConcurrentCallsPerServer(int callsPerServer) { + this.concurrentCallsPerServer = callsPerServer; +} } @VisibleForTesting @@ -280,6 +289,7 @@ public class MetricsConnection implements StatisticTrackable { @VisibleForTesting protected final Counter metaCacheNumClearRegion; @VisibleForTesting protected final Counter hedgedReadOps; @VisibleForTesting protected final Counter hedgedReadWin; + @VisibleForTesting protected final Histogram concurrentCallsPerServerHist; // dynamic metrics @@ -348,6 +358,8 @@ public class MetricsConnection implements StatisticTrackable { this.putTracker = new CallTracker(this.registry, "Mutate", "Put", scope); this.multiTracker = new CallTracker(this.registry, "Multi", scope); this.runnerStats = new RunnerStats(this.registry); +this.concurrentCallsPerServerHist = registry.newHistogram(this.getClass(), + "concurrentCallsPerServer", scope); this.reporter = new JmxReporter(this.registry); this.reporter.start(); @@ -450,6 +462,10 @@ public class MetricsConnection implements StatisticTrackable { /** Report RPC context to metrics system. */ public void updateRpc(MethodDescriptor method, Message param, CallStats stats) { +int callsPerServer = stats.getConcurrentCallsPerServer(); +if (callsPerServer > 0) { + concurrentCallsPerServerHist.update(callsPerServer); +} // this implementation is tied directly to protobuf implementation details. would be better // if we could dispatch based on something static, ie, request Message type. if (method.getService() == ClientService.getDescriptor()) { http://git-wip-us.apache.org/repos/asf/hbase/blob/66d348a3/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java index a110b8d..caa19b8 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java @@ -415,6 +415,7 @@ public abstract class AbstractRpcClient implements RpcC if (count > maxConcurrentCallsPerServer) { throw new ServerTooBusyException(addr, count); } + cs.setConcurrentCallsPerServer(count); T connection = getConnection(remoteId); connection.sendRequest(call, hrc); } catch (Exception e) {
[4/4] hbase git commit: HBASE-18559 Add histogram to MetricsConnection to track concurrent calls per server
HBASE-18559 Add histogram to MetricsConnection to track concurrent calls per server Signed-off-by: Andrew PurtellProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/759110c2 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/759110c2 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/759110c2 Branch: refs/heads/branch-2 Commit: 759110c2254ce043467b554746776c8beb0ccfd6 Parents: 55987ef Author: Robert Yokota Authored: Thu Aug 10 14:13:04 2017 -0700 Committer: Andrew Purtell Committed: Fri Sep 29 17:12:26 2017 -0700 -- .../hadoop/hbase/client/MetricsConnection.java | 16 .../apache/hadoop/hbase/ipc/AbstractRpcClient.java | 1 + 2 files changed, 17 insertions(+) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/759110c2/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java index c54729b..b88baa4 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java @@ -73,6 +73,7 @@ public class MetricsConnection implements StatisticTrackable { private long responseSizeBytes = 0; private long startTime = 0; private long callTimeMs = 0; +private int concurrentCallsPerServer = 0; public long getRequestSizeBytes() { return requestSizeBytes; @@ -105,6 +106,14 @@ public class MetricsConnection implements StatisticTrackable { public void setCallTimeMs(long callTimeMs) { this.callTimeMs = callTimeMs; } + +public int getConcurrentCallsPerServer() { + return concurrentCallsPerServer; +} + +public void setConcurrentCallsPerServer(int callsPerServer) { + this.concurrentCallsPerServer = callsPerServer; +} } @VisibleForTesting @@ -271,6 +280,7 @@ public class MetricsConnection implements StatisticTrackable { @VisibleForTesting protected final Counter metaCacheNumClearRegion; @VisibleForTesting protected final Counter hedgedReadOps; @VisibleForTesting protected final Counter hedgedReadWin; + @VisibleForTesting protected final Histogram concurrentCallsPerServerHist; // dynamic metrics @@ -327,6 +337,8 @@ public class MetricsConnection implements StatisticTrackable { this.putTracker = new CallTracker(this.registry, "Mutate", "Put", scope); this.multiTracker = new CallTracker(this.registry, "Multi", scope); this.runnerStats = new RunnerStats(this.registry); +this.concurrentCallsPerServerHist = registry.histogram(name(MetricsConnection.class, + "concurrentCallsPerServer", scope)); this.reporter = JmxReporter.forRegistry(this.registry).build(); this.reporter.start(); @@ -422,6 +434,10 @@ public class MetricsConnection implements StatisticTrackable { /** Report RPC context to metrics system. */ public void updateRpc(MethodDescriptor method, Message param, CallStats stats) { +int callsPerServer = stats.getConcurrentCallsPerServer(); +if (callsPerServer > 0) { + concurrentCallsPerServerHist.update(callsPerServer); +} // this implementation is tied directly to protobuf implementation details. would be better // if we could dispatch based on something static, ie, request Message type. if (method.getService() == ClientService.getDescriptor()) { http://git-wip-us.apache.org/repos/asf/hbase/blob/759110c2/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java index de4dea4..22da05a 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java @@ -416,6 +416,7 @@ public abstract class AbstractRpcClient implements RpcC if (count > maxConcurrentCallsPerServer) { throw new ServerTooBusyException(addr, count); } + cs.setConcurrentCallsPerServer(count); T connection = getConnection(remoteId); connection.sendRequest(call, hrc); } catch (Exception e) {
[3/4] hbase git commit: HBASE-18559 Add histogram to MetricsConnection to track concurrent calls per server
HBASE-18559 Add histogram to MetricsConnection to track concurrent calls per server Signed-off-by: Andrew PurtellProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/c835dcc7 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/c835dcc7 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/c835dcc7 Branch: refs/heads/master Commit: c835dcc7e70cc13415e60198ed4fb9c0e7339ac4 Parents: f20580a Author: Robert Yokota Authored: Thu Aug 10 14:13:04 2017 -0700 Committer: Andrew Purtell Committed: Fri Sep 29 17:12:26 2017 -0700 -- .../hadoop/hbase/client/MetricsConnection.java | 16 .../apache/hadoop/hbase/ipc/AbstractRpcClient.java | 1 + 2 files changed, 17 insertions(+) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/c835dcc7/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java index c54729b..b88baa4 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java @@ -73,6 +73,7 @@ public class MetricsConnection implements StatisticTrackable { private long responseSizeBytes = 0; private long startTime = 0; private long callTimeMs = 0; +private int concurrentCallsPerServer = 0; public long getRequestSizeBytes() { return requestSizeBytes; @@ -105,6 +106,14 @@ public class MetricsConnection implements StatisticTrackable { public void setCallTimeMs(long callTimeMs) { this.callTimeMs = callTimeMs; } + +public int getConcurrentCallsPerServer() { + return concurrentCallsPerServer; +} + +public void setConcurrentCallsPerServer(int callsPerServer) { + this.concurrentCallsPerServer = callsPerServer; +} } @VisibleForTesting @@ -271,6 +280,7 @@ public class MetricsConnection implements StatisticTrackable { @VisibleForTesting protected final Counter metaCacheNumClearRegion; @VisibleForTesting protected final Counter hedgedReadOps; @VisibleForTesting protected final Counter hedgedReadWin; + @VisibleForTesting protected final Histogram concurrentCallsPerServerHist; // dynamic metrics @@ -327,6 +337,8 @@ public class MetricsConnection implements StatisticTrackable { this.putTracker = new CallTracker(this.registry, "Mutate", "Put", scope); this.multiTracker = new CallTracker(this.registry, "Multi", scope); this.runnerStats = new RunnerStats(this.registry); +this.concurrentCallsPerServerHist = registry.histogram(name(MetricsConnection.class, + "concurrentCallsPerServer", scope)); this.reporter = JmxReporter.forRegistry(this.registry).build(); this.reporter.start(); @@ -422,6 +434,10 @@ public class MetricsConnection implements StatisticTrackable { /** Report RPC context to metrics system. */ public void updateRpc(MethodDescriptor method, Message param, CallStats stats) { +int callsPerServer = stats.getConcurrentCallsPerServer(); +if (callsPerServer > 0) { + concurrentCallsPerServerHist.update(callsPerServer); +} // this implementation is tied directly to protobuf implementation details. would be better // if we could dispatch based on something static, ie, request Message type. if (method.getService() == ClientService.getDescriptor()) { http://git-wip-us.apache.org/repos/asf/hbase/blob/c835dcc7/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java index de4dea4..22da05a 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java @@ -416,6 +416,7 @@ public abstract class AbstractRpcClient implements RpcC if (count > maxConcurrentCallsPerServer) { throw new ServerTooBusyException(addr, count); } + cs.setConcurrentCallsPerServer(count); T connection = getConnection(remoteId); connection.sendRequest(call, hrc); } catch (Exception e) {
[1/4] hbase git commit: HBASE-18559 Add histogram to MetricsConnection to track concurrent calls per server
Repository: hbase Updated Branches: refs/heads/branch-1 b2943504b -> 831e31b34 refs/heads/branch-1.4 790d006cc -> 66d348a3f refs/heads/branch-2 55987efdc -> 759110c22 refs/heads/master f20580a53 -> c835dcc7e HBASE-18559 Add histogram to MetricsConnection to track concurrent calls per server Signed-off-by: Andrew PurtellProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/831e31b3 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/831e31b3 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/831e31b3 Branch: refs/heads/branch-1 Commit: 831e31b34b6c72a43ee90effc8ca58e84246f4b0 Parents: b294350 Author: Robert Yokota Authored: Thu Aug 10 14:13:04 2017 -0700 Committer: Andrew Purtell Committed: Fri Sep 29 17:12:18 2017 -0700 -- .../hadoop/hbase/client/MetricsConnection.java | 16 .../apache/hadoop/hbase/ipc/AbstractRpcClient.java | 1 + 2 files changed, 17 insertions(+) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/831e31b3/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java index 7180ac2..6328d7f 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java @@ -71,6 +71,7 @@ public class MetricsConnection implements StatisticTrackable { private long responseSizeBytes = 0; private long startTime = 0; private long callTimeMs = 0; +private int concurrentCallsPerServer = 0; public long getRequestSizeBytes() { return requestSizeBytes; @@ -103,6 +104,14 @@ public class MetricsConnection implements StatisticTrackable { public void setCallTimeMs(long callTimeMs) { this.callTimeMs = callTimeMs; } + +public int getConcurrentCallsPerServer() { + return concurrentCallsPerServer; +} + +public void setConcurrentCallsPerServer(int callsPerServer) { + this.concurrentCallsPerServer = callsPerServer; +} } @VisibleForTesting @@ -280,6 +289,7 @@ public class MetricsConnection implements StatisticTrackable { @VisibleForTesting protected final Counter metaCacheNumClearRegion; @VisibleForTesting protected final Counter hedgedReadOps; @VisibleForTesting protected final Counter hedgedReadWin; + @VisibleForTesting protected final Histogram concurrentCallsPerServerHist; // dynamic metrics @@ -348,6 +358,8 @@ public class MetricsConnection implements StatisticTrackable { this.putTracker = new CallTracker(this.registry, "Mutate", "Put", scope); this.multiTracker = new CallTracker(this.registry, "Multi", scope); this.runnerStats = new RunnerStats(this.registry); +this.concurrentCallsPerServerHist = registry.newHistogram(this.getClass(), + "concurrentCallsPerServer", scope); this.reporter = new JmxReporter(this.registry); this.reporter.start(); @@ -450,6 +462,10 @@ public class MetricsConnection implements StatisticTrackable { /** Report RPC context to metrics system. */ public void updateRpc(MethodDescriptor method, Message param, CallStats stats) { +int callsPerServer = stats.getConcurrentCallsPerServer(); +if (callsPerServer > 0) { + concurrentCallsPerServerHist.update(callsPerServer); +} // this implementation is tied directly to protobuf implementation details. would be better // if we could dispatch based on something static, ie, request Message type. if (method.getService() == ClientService.getDescriptor()) { http://git-wip-us.apache.org/repos/asf/hbase/blob/831e31b3/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java index a110b8d..caa19b8 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AbstractRpcClient.java @@ -415,6 +415,7 @@ public abstract class AbstractRpcClient implements RpcC if (count > maxConcurrentCallsPerServer) { throw new ServerTooBusyException(addr, count); } + cs.setConcurrentCallsPerServer(count); T connection = getConnection(remoteId); connection.sendRequest(call, hrc); } catch (Exception e) {
hbase git commit: HBASE-18814 Improve TableSnapshotInputFormat to allow more multiple mappers per region
Repository: hbase Updated Branches: refs/heads/branch-2 d142f0712 -> 55987efdc HBASE-18814 Improve TableSnapshotInputFormat to allow more multiple mappers per region Signed-off-by: Ashu PachauriProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/55987efd Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/55987efd Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/55987efd Branch: refs/heads/branch-2 Commit: 55987efdcfb9f9a2110cd7695edc39680729bb64 Parents: d142f07 Author: libisthanks Authored: Wed Sep 27 12:33:53 2017 +0800 Committer: Ashu Pachauri Committed: Fri Sep 29 16:21:51 2017 -0700 -- ...IntegrationTestTableSnapshotInputFormat.java | 4 +- .../hadoop/hbase/mapred/TableMapReduceUtil.java | 38 ++ .../hbase/mapred/TableSnapshotInputFormat.java | 18 +++ .../hbase/mapreduce/TableMapReduceUtil.java | 38 ++ .../mapreduce/TableSnapshotInputFormat.java | 24 +++- .../mapreduce/TableSnapshotInputFormatImpl.java | 115 --- .../mapred/TestTableSnapshotInputFormat.java| 41 --- .../TableSnapshotInputFormatTestBase.java | 23 ++-- .../mapreduce/TestTableSnapshotInputFormat.java | 41 --- .../hbase/client/ClientSideRegionScanner.java | 2 + .../hadoop/hbase/util/RegionSplitter.java | 71 .../hadoop/hbase/util/TestRegionSplitter.java | 20 12 files changed, 383 insertions(+), 52 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/55987efd/hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestTableSnapshotInputFormat.java -- diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestTableSnapshotInputFormat.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestTableSnapshotInputFormat.java index 1a152e8..2df1c4b 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestTableSnapshotInputFormat.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestTableSnapshotInputFormat.java @@ -151,7 +151,7 @@ public class IntegrationTestTableSnapshotInputFormat extends IntegrationTestBase int expectedNumSplits = numRegions > 2 ? numRegions - 2 : numRegions; org.apache.hadoop.hbase.mapreduce.TestTableSnapshotInputFormat.doTestWithMapReduce(util, -tableName, snapshotName, START_ROW, END_ROW, tableDir, numRegions, +tableName, snapshotName, START_ROW, END_ROW, tableDir, numRegions, 1, expectedNumSplits, false); } else if (mr.equalsIgnoreCase(MAPRED_IMPLEMENTATION)) { /* @@ -165,7 +165,7 @@ public class IntegrationTestTableSnapshotInputFormat extends IntegrationTestBase int expectedNumSplits = numRegions; org.apache.hadoop.hbase.mapred.TestTableSnapshotInputFormat.doTestWithMapReduce(util, -tableName, snapshotName, MAPRED_START_ROW, MAPRED_END_ROW, tableDir, numRegions, +tableName, snapshotName, MAPRED_START_ROW, MAPRED_END_ROW, tableDir, numRegions, 1, expectedNumSplits, false); } else { throw new IllegalArgumentException("Unrecognized mapreduce implementation: " + mr +"."); http://git-wip-us.apache.org/repos/asf/hbase/blob/55987efd/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapred/TableMapReduceUtil.java -- diff --git a/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapred/TableMapReduceUtil.java b/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapred/TableMapReduceUtil.java index 35dbf02..0427f50 100644 --- a/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapred/TableMapReduceUtil.java +++ b/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapred/TableMapReduceUtil.java @@ -33,6 +33,7 @@ import org.apache.hadoop.hbase.mapreduce.ResultSerialization; import org.apache.hadoop.hbase.security.User; import org.apache.hadoop.hbase.security.UserProvider; import org.apache.hadoop.hbase.security.token.TokenUtil; +import org.apache.hadoop.hbase.util.RegionSplitter; import org.apache.hadoop.mapred.FileInputFormat; import org.apache.hadoop.mapred.InputFormat; import org.apache.hadoop.mapred.JobConf; @@ -186,6 +187,43 @@ public class TableMapReduceUtil { } /** + * Sets up the job for reading from a table snapshot. It bypasses hbase servers + * and read directly from snapshot files. + * + * @param snapshotName The name of the snapshot (of a table) to read from. + * @param columns The columns to scan. + * @param mapper The mapper class to use. + * @param outputKeyClass The class of the output key. + * @param
hbase git commit: HBASE-18890, Backport HBASE-14499 (Master coprocessors shutdown will not happen on master abort) to branch-1
Repository: hbase Updated Branches: refs/heads/branch-1.4 8148a75cb -> 790d006cc HBASE-18890, Backport HBASE-14499 (Master coprocessors shutdown will not happen on master abort) to branch-1 Signed-off-by: tedyuProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/790d006c Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/790d006c Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/790d006c Branch: refs/heads/branch-1.4 Commit: 790d006cc29e62450bf489ec3177be7de2290ff7 Parents: 8148a75 Author: Pankaj Kumar Authored: Thu Sep 28 20:41:28 2017 +0800 Committer: tedyu Committed: Fri Sep 29 16:21:20 2017 -0700 -- .../src/main/java/org/apache/hadoop/hbase/master/HMaster.java | 7 ++- 1 file changed, 6 insertions(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/790d006c/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 136c7d4..29307c9 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 @@ -2551,7 +2551,12 @@ public class HMaster extends HRegionServer implements MasterServices, Server { getLoadedCoprocessors()); } if (t != null) LOG.fatal(msg, t); -stop(msg); + +try { + stopMaster(); +} catch (IOException e) { + LOG.error("Exception occurred while stopping master", e); +} } @Override
hbase git commit: HBASE-18890, Backport HBASE-14499 (Master coprocessors shutdown will not happen on master abort) to branch-1
Repository: hbase Updated Branches: refs/heads/branch-1 93ad1aba7 -> b2943504b HBASE-18890, Backport HBASE-14499 (Master coprocessors shutdown will not happen on master abort) to branch-1 Signed-off-by: tedyuProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/b2943504 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/b2943504 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/b2943504 Branch: refs/heads/branch-1 Commit: b2943504b867e7b26e7c6433f026a602ef42a0ab Parents: 93ad1ab Author: Pankaj Kumar Authored: Thu Sep 28 20:41:28 2017 +0800 Committer: tedyu Committed: Fri Sep 29 16:20:52 2017 -0700 -- .../src/main/java/org/apache/hadoop/hbase/master/HMaster.java | 7 ++- 1 file changed, 6 insertions(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/b2943504/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 136c7d4..29307c9 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 @@ -2551,7 +2551,12 @@ public class HMaster extends HRegionServer implements MasterServices, Server { getLoadedCoprocessors()); } if (t != null) LOG.fatal(msg, t); -stop(msg); + +try { + stopMaster(); +} catch (IOException e) { + LOG.error("Exception occurred while stopping master", e); +} } @Override
hbase git commit: HBASE-18904 Missing break in NEXT_ROW case of FilterList#mergeReturnCodeForOrOperator()
Repository: hbase Updated Branches: refs/heads/branch-2 5917ad4c0 -> d142f0712 HBASE-18904 Missing break in NEXT_ROW case of FilterList#mergeReturnCodeForOrOperator() Signed-off-by: tedyuProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/d142f071 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/d142f071 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/d142f071 Branch: refs/heads/branch-2 Commit: d142f071295f67177074cd130eb0ee2d30bdfbcd Parents: 5917ad4 Author: Biju Nair Authored: Fri Sep 29 16:55:54 2017 -0400 Committer: tedyu Committed: Fri Sep 29 16:19:39 2017 -0700 -- .../src/main/java/org/apache/hadoop/hbase/filter/FilterList.java | 2 ++ 1 file changed, 2 insertions(+) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/d142f071/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java index 7f2405d..033ca83 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java @@ -566,6 +566,7 @@ final public class FilterList extends FilterBase { if (isInReturnCodes(rc, ReturnCode.NEXT_ROW)) { return ReturnCode.NEXT_ROW; } + break; case SEEK_NEXT_USING_HINT: if (isInReturnCodes(rc, ReturnCode.INCLUDE, ReturnCode.INCLUDE_AND_NEXT_COL, ReturnCode.INCLUDE_AND_SEEK_NEXT_ROW)) { @@ -577,6 +578,7 @@ final public class FilterList extends FilterBase { if (isInReturnCodes(rc, ReturnCode.SEEK_NEXT_USING_HINT)) { return ReturnCode.SEEK_NEXT_USING_HINT; } + break; } throw new IllegalStateException( "Received code is not valid. rc: " + rc + ", localRC: " + localRC);
hbase git commit: HBASE-18814 Improve TableSnapshotInputFormat to allow more multiple mappers per region
Repository: hbase Updated Branches: refs/heads/master ca87d05a5 -> f20580a53 HBASE-18814 Improve TableSnapshotInputFormat to allow more multiple mappers per region Signed-off-by: Ashu PachauriProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/f20580a5 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/f20580a5 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/f20580a5 Branch: refs/heads/master Commit: f20580a53083b69eec3d766cf2a1f99d0bff9747 Parents: ca87d05 Author: libisthanks Authored: Wed Sep 27 12:33:53 2017 +0800 Committer: Ashu Pachauri Committed: Fri Sep 29 16:12:39 2017 -0700 -- ...IntegrationTestTableSnapshotInputFormat.java | 4 +- .../hadoop/hbase/mapred/TableMapReduceUtil.java | 38 ++ .../hbase/mapred/TableSnapshotInputFormat.java | 18 +++ .../hbase/mapreduce/TableMapReduceUtil.java | 38 ++ .../mapreduce/TableSnapshotInputFormat.java | 24 +++- .../mapreduce/TableSnapshotInputFormatImpl.java | 115 --- .../mapred/TestTableSnapshotInputFormat.java| 41 --- .../TableSnapshotInputFormatTestBase.java | 23 ++-- .../mapreduce/TestTableSnapshotInputFormat.java | 41 --- .../hbase/client/ClientSideRegionScanner.java | 2 + .../hadoop/hbase/util/RegionSplitter.java | 71 .../hadoop/hbase/util/TestRegionSplitter.java | 20 12 files changed, 383 insertions(+), 52 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/f20580a5/hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestTableSnapshotInputFormat.java -- diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestTableSnapshotInputFormat.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestTableSnapshotInputFormat.java index 1a152e8..2df1c4b 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestTableSnapshotInputFormat.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestTableSnapshotInputFormat.java @@ -151,7 +151,7 @@ public class IntegrationTestTableSnapshotInputFormat extends IntegrationTestBase int expectedNumSplits = numRegions > 2 ? numRegions - 2 : numRegions; org.apache.hadoop.hbase.mapreduce.TestTableSnapshotInputFormat.doTestWithMapReduce(util, -tableName, snapshotName, START_ROW, END_ROW, tableDir, numRegions, +tableName, snapshotName, START_ROW, END_ROW, tableDir, numRegions, 1, expectedNumSplits, false); } else if (mr.equalsIgnoreCase(MAPRED_IMPLEMENTATION)) { /* @@ -165,7 +165,7 @@ public class IntegrationTestTableSnapshotInputFormat extends IntegrationTestBase int expectedNumSplits = numRegions; org.apache.hadoop.hbase.mapred.TestTableSnapshotInputFormat.doTestWithMapReduce(util, -tableName, snapshotName, MAPRED_START_ROW, MAPRED_END_ROW, tableDir, numRegions, +tableName, snapshotName, MAPRED_START_ROW, MAPRED_END_ROW, tableDir, numRegions, 1, expectedNumSplits, false); } else { throw new IllegalArgumentException("Unrecognized mapreduce implementation: " + mr +"."); http://git-wip-us.apache.org/repos/asf/hbase/blob/f20580a5/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapred/TableMapReduceUtil.java -- diff --git a/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapred/TableMapReduceUtil.java b/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapred/TableMapReduceUtil.java index 35dbf02..0427f50 100644 --- a/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapred/TableMapReduceUtil.java +++ b/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapred/TableMapReduceUtil.java @@ -33,6 +33,7 @@ import org.apache.hadoop.hbase.mapreduce.ResultSerialization; import org.apache.hadoop.hbase.security.User; import org.apache.hadoop.hbase.security.UserProvider; import org.apache.hadoop.hbase.security.token.TokenUtil; +import org.apache.hadoop.hbase.util.RegionSplitter; import org.apache.hadoop.mapred.FileInputFormat; import org.apache.hadoop.mapred.InputFormat; import org.apache.hadoop.mapred.JobConf; @@ -186,6 +187,43 @@ public class TableMapReduceUtil { } /** + * Sets up the job for reading from a table snapshot. It bypasses hbase servers + * and read directly from snapshot files. + * + * @param snapshotName The name of the snapshot (of a table) to read from. + * @param columns The columns to scan. + * @param mapper The mapper class to use. + * @param outputKeyClass The class of the output key. + * @param
[4/4] hbase git commit: HBASE-18436 Add client-side hedged read metrics (Yun Zhao)
HBASE-18436 Add client-side hedged read metrics (Yun Zhao) Conflicts: hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestReplicasClient.java Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/8148a75c Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/8148a75c Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/8148a75c Branch: refs/heads/branch-1.4 Commit: 8148a75cb7129341fef5e169a6ec08a55aeb416d Parents: bb8c716 Author: Andrew PurtellAuthored: Fri Sep 29 14:02:49 2017 -0700 Committer: Andrew Purtell Committed: Fri Sep 29 15:43:13 2017 -0700 -- .../hadoop/hbase/client/MetricsConnection.java | 14 ++ .../RpcRetryingCallerWithReadReplicas.java | 11 +- .../hadoop/hbase/client/TestReplicasClient.java | 129 --- .../TestSplitTransactionOnCluster.java | 6 +- 4 files changed, 134 insertions(+), 26 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/8148a75c/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java index 9dd803a..7180ac2 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java @@ -278,6 +278,8 @@ public class MetricsConnection implements StatisticTrackable { @VisibleForTesting protected final RunnerStats runnerStats; @VisibleForTesting protected final Counter metaCacheNumClearServer; @VisibleForTesting protected final Counter metaCacheNumClearRegion; + @VisibleForTesting protected final Counter hedgedReadOps; + @VisibleForTesting protected final Counter hedgedReadWin; // dynamic metrics @@ -336,6 +338,8 @@ public class MetricsConnection implements StatisticTrackable { "metaCacheNumClearServer", scope); this.metaCacheNumClearRegion = registry.newCounter(this.getClass(), "metaCacheNumClearRegion", scope); +this.hedgedReadOps = registry.newCounter(this.getClass(), "hedgedReadOps", scope); +this.hedgedReadWin = registry.newCounter(this.getClass(), "hedgedReadWin", scope); this.getTracker = new CallTracker(this.registry, "Get", scope); this.scanTracker = new CallTracker(this.registry, "Scan", scope); this.appendTracker = new CallTracker(this.registry, "Mutate", "Append", scope); @@ -395,6 +399,16 @@ public class MetricsConnection implements StatisticTrackable { metaCacheNumClearRegion.inc(); } + /** Increment the number of hedged read that have occurred. */ + public void incrHedgedReadOps() { +hedgedReadOps.inc(); + } + + /** Increment the number of hedged read returned faster than the original read. */ + public void incrHedgedReadWin() { +hedgedReadWin.inc(); + } + /** Increment the number of normal runner counts. */ public void incrNormalRunners() { this.runnerStats.incrNormalRunners(); http://git-wip-us.apache.org/repos/asf/hbase/blob/8148a75c/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java index cbbe9f4..5a41233 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java @@ -244,6 +244,9 @@ public class RpcRetryingCallerWithReadReplicas { if (f != null) { return f.get(); //great we got a response } + if (cConnection.getConnectionMetrics() != null) { +cConnection.getConnectionMetrics().incrHedgedReadOps(); + } } catch (ExecutionException e) { // We ignore the ExecutionException and continue with the secondary replicas if (LOG.isDebugEnabled()) { @@ -267,13 +270,17 @@ public class RpcRetryingCallerWithReadReplicas { } try { - Future f = cs.pollForFirstSuccessfullyCompletedTask(operationTimeout, - TimeUnit.MILLISECONDS, startIndex, endIndex); + ResultBoundedCompletionService.QueueingFuture f = + cs.pollForFirstSuccessfullyCompletedTask(operationTimeout,
[1/4] hbase git commit: HBASE-18436 Add client-side hedged read metrics (Yun Zhao)
Repository: hbase Updated Branches: refs/heads/branch-1 aa86657a5 -> 93ad1aba7 refs/heads/branch-1.4 bb8c716fe -> 8148a75cb refs/heads/branch-2 5cbf158aa -> 5917ad4c0 refs/heads/master 3bd824fac -> ca87d05a5 HBASE-18436 Add client-side hedged read metrics (Yun Zhao) Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/5917ad4c Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/5917ad4c Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/5917ad4c Branch: refs/heads/branch-2 Commit: 5917ad4c0cd017e8beba6d5faa198cf80f04f415 Parents: 5cbf158 Author: Andrew PurtellAuthored: Fri Sep 29 14:02:49 2017 -0700 Committer: Andrew Purtell Committed: Fri Sep 29 15:36:42 2017 -0700 -- .../hadoop/hbase/client/MetricsConnection.java | 14 +++ .../RpcRetryingCallerWithReadReplicas.java | 11 +- .../hadoop/hbase/client/TestReplicasClient.java | 126 --- .../TestSplitTransactionOnCluster.java | 6 +- 4 files changed, 132 insertions(+), 25 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/5917ad4c/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java index 31612f3..c54729b 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java @@ -269,6 +269,8 @@ public class MetricsConnection implements StatisticTrackable { @VisibleForTesting protected final RunnerStats runnerStats; @VisibleForTesting protected final Counter metaCacheNumClearServer; @VisibleForTesting protected final Counter metaCacheNumClearRegion; + @VisibleForTesting protected final Counter hedgedReadOps; + @VisibleForTesting protected final Counter hedgedReadWin; // dynamic metrics @@ -315,6 +317,8 @@ public class MetricsConnection implements StatisticTrackable { "metaCacheNumClearServer", scope)); this.metaCacheNumClearRegion = registry.counter(name(this.getClass(), "metaCacheNumClearRegion", scope)); +this.hedgedReadOps = registry.counter(name(this.getClass(), "hedgedReadOps", scope)); +this.hedgedReadWin = registry.counter(name(this.getClass(), "hedgedReadWin", scope)); this.getTracker = new CallTracker(this.registry, "Get", scope); this.scanTracker = new CallTracker(this.registry, "Scan", scope); this.appendTracker = new CallTracker(this.registry, "Mutate", "Append", scope); @@ -373,6 +377,16 @@ public class MetricsConnection implements StatisticTrackable { metaCacheNumClearRegion.inc(); } + /** Increment the number of hedged read that have occurred. */ + public void incrHedgedReadOps() { +hedgedReadOps.inc(); + } + + /** Increment the number of hedged read returned faster than the original read. */ + public void incrHedgedReadWin() { +hedgedReadWin.inc(); + } + /** Increment the number of normal runner counts. */ public void incrNormalRunners() { this.runnerStats.incrNormalRunners(); http://git-wip-us.apache.org/repos/asf/hbase/blob/5917ad4c/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java index e7a4ba6..c6ba228 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java @@ -216,6 +216,9 @@ public class RpcRetryingCallerWithReadReplicas { if (f != null) { return f.get(); //great we got a response } + if (cConnection.getConnectionMetrics() != null) { +cConnection.getConnectionMetrics().incrHedgedReadOps(); + } } catch (ExecutionException e) { // We ignore the ExecutionException and continue with the secondary replicas if (LOG.isDebugEnabled()) { @@ -238,13 +241,17 @@ public class RpcRetryingCallerWithReadReplicas { addCallsForReplica(cs, rl, 1, rl.size() - 1); } try { - Future f = cs.pollForFirstSuccessfullyCompletedTask(operationTimeout, - TimeUnit.MILLISECONDS, startIndex, endIndex); + ResultBoundedCompletionService.QueueingFuture f = +
[3/4] hbase git commit: HBASE-18436 Add client-side hedged read metrics (Yun Zhao)
HBASE-18436 Add client-side hedged read metrics (Yun Zhao) Conflicts: hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestReplicasClient.java Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/93ad1aba Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/93ad1aba Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/93ad1aba Branch: refs/heads/branch-1 Commit: 93ad1aba7026ce2538df2e97865a88ff70abaa44 Parents: aa86657 Author: Andrew PurtellAuthored: Fri Sep 29 14:02:49 2017 -0700 Committer: Andrew Purtell Committed: Fri Sep 29 15:43:03 2017 -0700 -- .../hadoop/hbase/client/MetricsConnection.java | 14 ++ .../RpcRetryingCallerWithReadReplicas.java | 11 +- .../hadoop/hbase/client/TestReplicasClient.java | 129 --- .../TestSplitTransactionOnCluster.java | 6 +- 4 files changed, 134 insertions(+), 26 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/93ad1aba/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java index 9dd803a..7180ac2 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java @@ -278,6 +278,8 @@ public class MetricsConnection implements StatisticTrackable { @VisibleForTesting protected final RunnerStats runnerStats; @VisibleForTesting protected final Counter metaCacheNumClearServer; @VisibleForTesting protected final Counter metaCacheNumClearRegion; + @VisibleForTesting protected final Counter hedgedReadOps; + @VisibleForTesting protected final Counter hedgedReadWin; // dynamic metrics @@ -336,6 +338,8 @@ public class MetricsConnection implements StatisticTrackable { "metaCacheNumClearServer", scope); this.metaCacheNumClearRegion = registry.newCounter(this.getClass(), "metaCacheNumClearRegion", scope); +this.hedgedReadOps = registry.newCounter(this.getClass(), "hedgedReadOps", scope); +this.hedgedReadWin = registry.newCounter(this.getClass(), "hedgedReadWin", scope); this.getTracker = new CallTracker(this.registry, "Get", scope); this.scanTracker = new CallTracker(this.registry, "Scan", scope); this.appendTracker = new CallTracker(this.registry, "Mutate", "Append", scope); @@ -395,6 +399,16 @@ public class MetricsConnection implements StatisticTrackable { metaCacheNumClearRegion.inc(); } + /** Increment the number of hedged read that have occurred. */ + public void incrHedgedReadOps() { +hedgedReadOps.inc(); + } + + /** Increment the number of hedged read returned faster than the original read. */ + public void incrHedgedReadWin() { +hedgedReadWin.inc(); + } + /** Increment the number of normal runner counts. */ public void incrNormalRunners() { this.runnerStats.incrNormalRunners(); http://git-wip-us.apache.org/repos/asf/hbase/blob/93ad1aba/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java index cbbe9f4..5a41233 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java @@ -244,6 +244,9 @@ public class RpcRetryingCallerWithReadReplicas { if (f != null) { return f.get(); //great we got a response } + if (cConnection.getConnectionMetrics() != null) { +cConnection.getConnectionMetrics().incrHedgedReadOps(); + } } catch (ExecutionException e) { // We ignore the ExecutionException and continue with the secondary replicas if (LOG.isDebugEnabled()) { @@ -267,13 +270,17 @@ public class RpcRetryingCallerWithReadReplicas { } try { - Future f = cs.pollForFirstSuccessfullyCompletedTask(operationTimeout, - TimeUnit.MILLISECONDS, startIndex, endIndex); + ResultBoundedCompletionService.QueueingFuture f = + cs.pollForFirstSuccessfullyCompletedTask(operationTimeout, TimeUnit.MILLISECONDS,
[2/4] hbase git commit: HBASE-18436 Add client-side hedged read metrics (Yun Zhao)
HBASE-18436 Add client-side hedged read metrics (Yun Zhao) Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/ca87d05a Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/ca87d05a Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/ca87d05a Branch: refs/heads/master Commit: ca87d05a518338e64099f42c229d557b93ce51c8 Parents: 3bd824f Author: Andrew PurtellAuthored: Fri Sep 29 14:02:49 2017 -0700 Committer: Andrew Purtell Committed: Fri Sep 29 15:37:04 2017 -0700 -- .../hadoop/hbase/client/MetricsConnection.java | 14 +++ .../RpcRetryingCallerWithReadReplicas.java | 11 +- .../hadoop/hbase/client/TestReplicasClient.java | 126 --- .../TestSplitTransactionOnCluster.java | 6 +- 4 files changed, 132 insertions(+), 25 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/ca87d05a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java index 31612f3..c54729b 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MetricsConnection.java @@ -269,6 +269,8 @@ public class MetricsConnection implements StatisticTrackable { @VisibleForTesting protected final RunnerStats runnerStats; @VisibleForTesting protected final Counter metaCacheNumClearServer; @VisibleForTesting protected final Counter metaCacheNumClearRegion; + @VisibleForTesting protected final Counter hedgedReadOps; + @VisibleForTesting protected final Counter hedgedReadWin; // dynamic metrics @@ -315,6 +317,8 @@ public class MetricsConnection implements StatisticTrackable { "metaCacheNumClearServer", scope)); this.metaCacheNumClearRegion = registry.counter(name(this.getClass(), "metaCacheNumClearRegion", scope)); +this.hedgedReadOps = registry.counter(name(this.getClass(), "hedgedReadOps", scope)); +this.hedgedReadWin = registry.counter(name(this.getClass(), "hedgedReadWin", scope)); this.getTracker = new CallTracker(this.registry, "Get", scope); this.scanTracker = new CallTracker(this.registry, "Scan", scope); this.appendTracker = new CallTracker(this.registry, "Mutate", "Append", scope); @@ -373,6 +377,16 @@ public class MetricsConnection implements StatisticTrackable { metaCacheNumClearRegion.inc(); } + /** Increment the number of hedged read that have occurred. */ + public void incrHedgedReadOps() { +hedgedReadOps.inc(); + } + + /** Increment the number of hedged read returned faster than the original read. */ + public void incrHedgedReadWin() { +hedgedReadWin.inc(); + } + /** Increment the number of normal runner counts. */ public void incrNormalRunners() { this.runnerStats.incrNormalRunners(); http://git-wip-us.apache.org/repos/asf/hbase/blob/ca87d05a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java index e7a4ba6..c6ba228 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java @@ -216,6 +216,9 @@ public class RpcRetryingCallerWithReadReplicas { if (f != null) { return f.get(); //great we got a response } + if (cConnection.getConnectionMetrics() != null) { +cConnection.getConnectionMetrics().incrHedgedReadOps(); + } } catch (ExecutionException e) { // We ignore the ExecutionException and continue with the secondary replicas if (LOG.isDebugEnabled()) { @@ -238,13 +241,17 @@ public class RpcRetryingCallerWithReadReplicas { addCallsForReplica(cs, rl, 1, rl.size() - 1); } try { - Future f = cs.pollForFirstSuccessfullyCompletedTask(operationTimeout, - TimeUnit.MILLISECONDS, startIndex, endIndex); + ResultBoundedCompletionService.QueueingFuture f = + cs.pollForFirstSuccessfullyCompletedTask(operationTimeout, TimeUnit.MILLISECONDS, startIndex, endIndex); if (f == null) { throw new RetriesExhaustedException("Timed out after " + operationTimeout +
hbase git commit: HBASE-18904 Missing break in NEXT_ROW case of FilterList#mergeReturnCodeForOrOperator()
Repository: hbase Updated Branches: refs/heads/master b0e1a1509 -> 3bd824fac HBASE-18904 Missing break in NEXT_ROW case of FilterList#mergeReturnCodeForOrOperator() Signed-off-by: tedyuProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/3bd824fa Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/3bd824fa Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/3bd824fa Branch: refs/heads/master Commit: 3bd824facadd40dabb06e19ccad911be0ea6915a Parents: b0e1a15 Author: Biju Nair Authored: Fri Sep 29 16:55:54 2017 -0400 Committer: tedyu Committed: Fri Sep 29 15:31:10 2017 -0700 -- .../src/main/java/org/apache/hadoop/hbase/filter/FilterList.java | 2 ++ 1 file changed, 2 insertions(+) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/3bd824fa/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java index 7f2405d..033ca83 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java @@ -566,6 +566,7 @@ final public class FilterList extends FilterBase { if (isInReturnCodes(rc, ReturnCode.NEXT_ROW)) { return ReturnCode.NEXT_ROW; } + break; case SEEK_NEXT_USING_HINT: if (isInReturnCodes(rc, ReturnCode.INCLUDE, ReturnCode.INCLUDE_AND_NEXT_COL, ReturnCode.INCLUDE_AND_SEEK_NEXT_ROW)) { @@ -577,6 +578,7 @@ final public class FilterList extends FilterBase { if (isInReturnCodes(rc, ReturnCode.SEEK_NEXT_USING_HINT)) { return ReturnCode.SEEK_NEXT_USING_HINT; } + break; } throw new IllegalStateException( "Received code is not valid. rc: " + rc + ", localRC: " + localRC);
hbase git commit: Update Misty's timezone
Repository: hbase Updated Branches: refs/heads/master 4136ab338 -> b0e1a1509 Update Misty's timezone Signed-off-by: Misty Stanley-JonesProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/b0e1a150 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/b0e1a150 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/b0e1a150 Branch: refs/heads/master Commit: b0e1a150928a5eb5dca2f933dc55ac206977f3ca Parents: 4136ab3 Author: Misty Stanley-Jones Authored: Fri Sep 29 10:37:45 2017 -0700 Committer: Misty Stanley-Jones Committed: Fri Sep 29 10:37:45 2017 -0700 -- pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/b0e1a150/pom.xml -- diff --git a/pom.xml b/pom.xml index 13be3ab..272e4d4 100755 --- a/pom.xml +++ b/pom.xml @@ -431,7 +431,7 @@ misty Misty Stanley-Jones mi...@apache.org - +10 + -8 ndimiduk
[2/2] hbase git commit: HBASE-18883 Update Curator to 4.0
HBASE-18883 Update Curator to 4.0 Signed-off-by: zhangduoProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/5cbf158a Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/5cbf158a Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/5cbf158a Branch: refs/heads/branch-2 Commit: 5cbf158aaa431d37d4da784828dc0e1acd730733 Parents: 2e4c1b6 Author: Mike Drob Authored: Tue Sep 26 15:00:49 2017 -0500 Committer: Mike Drob Committed: Fri Sep 29 10:54:29 2017 -0500 -- pom.xml | 17 +++-- 1 file changed, 11 insertions(+), 6 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/5cbf158a/pom.xml -- diff --git a/pom.xml b/pom.xml index 6884e78..07643d1 100644 --- a/pom.xml +++ b/pom.xml @@ -1399,7 +1399,7 @@ 1.46 1.0.0-RC2 1.0.0 -2.12.0 +4.0.0 0.12 1.5.5 @@ -2022,13 +2022,14 @@ org.apache.curator -curator-recipes -${curator.version} - - -org.apache.curator curator-framework ${curator.version} + + +org.apache.zookeeper +zookeeper + + org.apache.curator @@ -2039,6 +2040,10 @@ com.google.guava guava + +org.apache.zookeeper +zookeeper +
[1/2] hbase git commit: HBASE-18883 Update Curator to 4.0
Repository: hbase Updated Branches: refs/heads/branch-2 2e4c1b628 -> 5cbf158aa refs/heads/master 239e68726 -> 4136ab338 HBASE-18883 Update Curator to 4.0 Signed-off-by: zhangduoProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/4136ab33 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/4136ab33 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/4136ab33 Branch: refs/heads/master Commit: 4136ab338d5691166e7e8c44f26aad6d273283d3 Parents: 239e687 Author: Mike Drob Authored: Tue Sep 26 15:00:49 2017 -0500 Committer: Mike Drob Committed: Fri Sep 29 10:39:57 2017 -0500 -- pom.xml | 17 +++-- 1 file changed, 11 insertions(+), 6 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/4136ab33/pom.xml -- diff --git a/pom.xml b/pom.xml index a684f3c..13be3ab 100755 --- a/pom.xml +++ b/pom.xml @@ -1436,7 +1436,7 @@ 1.46 1.0.0-RC2 1.0.0 -2.12.0 +4.0.0 0.12 1.5.5 @@ -2066,13 +2066,14 @@ org.apache.curator -curator-recipes -${curator.version} - - -org.apache.curator curator-framework ${curator.version} + + +org.apache.zookeeper +zookeeper + + org.apache.curator @@ -2083,6 +2084,10 @@ com.google.guava guava + +org.apache.zookeeper +zookeeper +
[41/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/CellUtil.EmptyCell.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/CellUtil.EmptyCell.html b/devapidocs/org/apache/hadoop/hbase/CellUtil.EmptyCell.html index d954202..9d59fef 100644 --- a/devapidocs/org/apache/hadoop/hbase/CellUtil.EmptyCell.html +++ b/devapidocs/org/apache/hadoop/hbase/CellUtil.EmptyCell.html @@ -122,7 +122,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private -private abstract static class CellUtil.EmptyCell +private abstract static class CellUtil.EmptyCell 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 Cell, SettableSequenceId @@ -282,7 +282,7 @@ implements EmptyCell -privateEmptyCell() +privateEmptyCell() @@ -299,7 +299,7 @@ implements setSequenceId -publicvoidsetSequenceId(longseqId) +publicvoidsetSequenceId(longseqId) Description copied from interface:SettableSequenceId Sets with the given seqId. @@ -314,7 +314,7 @@ implements getRowArray -publicbyte[]getRowArray() +publicbyte[]getRowArray() Description copied from interface:Cell Contiguous raw bytes that may start at any index in the containing array. Max length is Short.MAX_VALUE which is 32,767 bytes. @@ -332,7 +332,7 @@ implements getRowOffset -publicintgetRowOffset() +publicintgetRowOffset() Specified by: getRowOffsetin interfaceCell @@ -347,7 +347,7 @@ implements getRowLength -publicshortgetRowLength() +publicshortgetRowLength() Specified by: getRowLengthin interfaceCell @@ -362,7 +362,7 @@ implements getFamilyArray -publicbyte[]getFamilyArray() +publicbyte[]getFamilyArray() Description copied from interface:Cell Contiguous bytes composed of legal HDFS filename characters which may start at any index in the containing array. Max length is Byte.MAX_VALUE, which is 127 bytes. @@ -380,7 +380,7 @@ implements getFamilyOffset -publicintgetFamilyOffset() +publicintgetFamilyOffset() Specified by: getFamilyOffsetin interfaceCell @@ -395,7 +395,7 @@ implements getFamilyLength -publicbytegetFamilyLength() +publicbytegetFamilyLength() Specified by: getFamilyLengthin interfaceCell @@ -410,7 +410,7 @@ implements getQualifierArray -publicbyte[]getQualifierArray() +publicbyte[]getQualifierArray() Description copied from interface:Cell Contiguous raw bytes that may start at any index in the containing array. @@ -427,7 +427,7 @@ implements getQualifierOffset -publicintgetQualifierOffset() +publicintgetQualifierOffset() Specified by: getQualifierOffsetin interfaceCell @@ -442,7 +442,7 @@ implements getQualifierLength -publicintgetQualifierLength() +publicintgetQualifierLength() Specified by: getQualifierLengthin interfaceCell @@ -457,7 +457,7 @@ implements getSequenceId -publiclonggetSequenceId() +publiclonggetSequenceId() Description copied from interface:Cell A region-specific unique monotonically increasing sequence ID given to each Cell. It always exists for cells in the memstore but is not retained forever. It will be kept for @@ -477,7 +477,7 @@ implements getValueArray -publicbyte[]getValueArray() +publicbyte[]getValueArray() Description copied from interface:Cell Contiguous raw bytes that may start at any index in the containing array. Max length is Integer.MAX_VALUE which is 2,147,483,647 bytes. @@ -495,7 +495,7 @@ implements getValueOffset -publicintgetValueOffset() +publicintgetValueOffset() Specified by: getValueOffsetin interfaceCell @@ -510,7 +510,7 @@ implements getValueLength -publicintgetValueLength() +publicintgetValueLength() Specified by: getValueLengthin interfaceCell @@ -525,7 +525,7 @@ implements getTagsArray -publicbyte[]getTagsArray() +publicbyte[]getTagsArray() Description copied from interface:Cell Contiguous raw bytes representing tags that may start at any index in the containing array. @@ -542,7 +542,7 @@ implements getTagsOffset -publicintgetTagsOffset() +publicintgetTagsOffset() Specified by: getTagsOffsetin interfaceCell @@ -557,7 +557,7 @@ implements getTagsLength -publicintgetTagsLength() +publicintgetTagsLength() Description copied from interface:Cell HBase internally uses 2 bytes to store tags length in Cell. As the tags length is always a non-negative number, to make good use of the sign bit, http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/CellUtil.FirstOnRowByteBufferCell.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/CellUtil.FirstOnRowByteBufferCell.html b/devapidocs/org/apache/hadoop/hbase/CellUtil.FirstOnRowByteBufferCell.html index fc5a2e6..059b3b9 100644 ---
[10/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowByteBufferCell.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowByteBufferCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowByteBufferCell.html index 26125e3..eb6a00d 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowByteBufferCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowByteBufferCell.html @@ -28,3193 +28,3241 @@ 020 021import static org.apache.hadoop.hbase.HConstants.EMPTY_BYTE_ARRAY; 022import static org.apache.hadoop.hbase.Tag.TAG_LENGTH_SIZE; -023 -024import java.io.DataOutputStream; -025import java.io.IOException; -026import java.io.OutputStream; -027import java.math.BigDecimal; -028import java.nio.ByteBuffer; -029import java.util.ArrayList; -030import java.util.Arrays; -031import java.util.Iterator; -032import java.util.List; -033import java.util.Map.Entry; -034import java.util.NavigableMap; -035 -036import org.apache.hadoop.hbase.KeyValue.Type; -037import org.apache.yetus.audience.InterfaceAudience; -038import org.apache.yetus.audience.InterfaceAudience.Private; -039import org.apache.hadoop.hbase.io.HeapSize; -040import org.apache.hadoop.hbase.io.TagCompressionContext; -041import org.apache.hadoop.hbase.io.util.Dictionary; -042import org.apache.hadoop.hbase.io.util.StreamUtils; -043import org.apache.hadoop.hbase.util.ByteBufferUtils; -044import org.apache.hadoop.hbase.util.ByteRange; -045import org.apache.hadoop.hbase.util.Bytes; -046import org.apache.hadoop.hbase.util.ClassSize; -047 -048/** -049 * Utility methods helpful slinging {@link Cell} instances. -050 * Some methods below are for internal use only and are marked InterfaceAudience.Private at the -051 * method level. -052 */ -053@InterfaceAudience.Public -054public final class CellUtil { -055 -056 /** -057 * Private constructor to keep this class from being instantiated. -058 */ -059 private CellUtil(){} -060 -061 /*** ByteRange ***/ -062 -063 public static ByteRange fillRowRange(Cell cell, ByteRange range) { -064return range.set(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()); -065 } -066 -067 public static ByteRange fillFamilyRange(Cell cell, ByteRange range) { -068return range.set(cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength()); -069 } -070 -071 public static ByteRange fillQualifierRange(Cell cell, ByteRange range) { -072return range.set(cell.getQualifierArray(), cell.getQualifierOffset(), -073 cell.getQualifierLength()); -074 } -075 -076 public static ByteRange fillValueRange(Cell cell, ByteRange range) { -077return range.set(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength()); -078 } -079 -080 public static ByteRange fillTagRange(Cell cell, ByteRange range) { -081return range.set(cell.getTagsArray(), cell.getTagsOffset(), cell.getTagsLength()); -082 } -083 -084 /* get individual arrays for tests / -085 -086 public static byte[] cloneRow(Cell cell){ -087byte[] output = new byte[cell.getRowLength()]; -088copyRowTo(cell, output, 0); -089return output; -090 } -091 -092 public static byte[] cloneFamily(Cell cell){ -093byte[] output = new byte[cell.getFamilyLength()]; -094copyFamilyTo(cell, output, 0); -095return output; -096 } -097 -098 public static byte[] cloneQualifier(Cell cell){ -099byte[] output = new byte[cell.getQualifierLength()]; -100copyQualifierTo(cell, output, 0); -101return output; -102 } -103 -104 public static byte[] cloneValue(Cell cell){ -105byte[] output = new byte[cell.getValueLength()]; -106copyValueTo(cell, output, 0); -107return output; -108 } -109 -110 public static byte[] cloneTags(Cell cell) { -111byte[] output = new byte[cell.getTagsLength()]; -112copyTagTo(cell, output, 0); -113return output; -114 } -115 -116 /** -117 * Returns tag value in a new byte array. If server-side, use -118 * {@link Tag#getValueArray()} with appropriate {@link Tag#getValueOffset()} and -119 * {@link Tag#getValueLength()} instead to save on allocations. -120 * @param cell -121 * @return tag value in a new byte array. -122 */ -123 public static byte[] getTagArray(Cell cell){ -124byte[] output = new byte[cell.getTagsLength()]; -125copyTagTo(cell, output, 0); -126return output; -127 } -128 -129 -130 / copyTo **/ +023import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIMITER; +024import static org.apache.hadoop.hbase.KeyValue.getDelimiter; +025import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIM_ARRAY; +026 +027import java.io.DataOutputStream;
[42/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/index-all.html -- diff --git a/devapidocs/index-all.html b/devapidocs/index-all.html index e4f6817..40b1dfc 100644 --- a/devapidocs/index-all.html +++ b/devapidocs/index-all.html @@ -8217,10 +8217,6 @@ Deprecated. -calcIndexKey(byte[], byte[]) - Method in class org.apache.hadoop.hbase.KeyValue.RawBytesComparator - -Deprecated. - calcMruCap(int) - Static method in class org.apache.hadoop.hbase.master.balancer.MetricsStochasticBalancerSourceImpl Calculates the mru cache capacity from the metrics size @@ -12116,10 +12112,6 @@ clone() - Method in class org.apache.hadoop.hbase.monitoring.MonitoredTaskImpl -cloneAndAddTags(Cell, ListTag) - Static method in class org.apache.hadoop.hbase.KeyValue - -Create a new KeyValue by copying existing cell and adding new tags - cloneFamily(Cell) - Static method in class org.apache.hadoop.hbase.CellUtil cloneHdfsMobRegion(MapString, SnapshotProtos.SnapshotRegionManifest, RegionInfo) - Method in class org.apache.hadoop.hbase.snapshot.RestoreSnapshotHelper @@ -14359,11 +14351,9 @@ COMPARATOR - Static variable in class org.apache.hadoop.hbase.KeyValue Deprecated. -Use CellComparator.COMPARATOR instead +Use CellComparator.COMPARATOR instead. Deprecated for hbase 2.0, remove for hbase 3.0. -comparator - Variable in class org.apache.hadoop.hbase.KeyValue.RowOnlyComparator - COMPARATOR - Static variable in class org.apache.hadoop.hbase.master.cleaner.HFileCleaner comparator - Variable in class org.apache.hadoop.hbase.regionserver.AbstractMemStore @@ -14475,12 +14465,6 @@ Compare key portion of a KeyValue for keys in hbase:meta table. -compare(Cell, Cell) - Method in class org.apache.hadoop.hbase.KeyValue.RawBytesComparator - -Deprecated. - -compare(KeyValue, KeyValue) - Method in class org.apache.hadoop.hbase.KeyValue.RowOnlyComparator - compare(byte[], int, int, byte[], int, int) - Method in class org.apache.hadoop.hbase.mapreduce.Import.KeyValueWritableComparable.KeyValueWritableComparator compare(RegionState, RegionState) - Method in class org.apache.hadoop.hbase.master.assignment.RegionStates.RegionStateStampComparator @@ -14604,12 +14588,6 @@ Deprecated. -compareFlatKey(byte[], int, int, byte[], int, int) - Method in class org.apache.hadoop.hbase.KeyValue.RawBytesComparator - -Deprecated. -Since 0.99.2. - - compareForReplication(HTableDescriptor, HTableDescriptor) - Method in class org.apache.hadoop.hbase.client.HBaseAdmin Compare the contents of the descriptor with another one passed as a parameter for replication @@ -14672,10 +14650,6 @@ Deprecated. -compareOnlyKeyPortion(Cell, Cell) - Method in class org.apache.hadoop.hbase.KeyValue.RawBytesComparator - -Deprecated. - CompareOp() - Constructor for enum org.apache.hadoop.hbase.filter.CompareFilter.CompareOp Deprecated. @@ -17201,7 +17175,8 @@ Coprocessor - Interface in org.apache.hadoop.hbase -Coprocessor interface. +Base interface for the 4 coprocessors - MasterCoprocessor, RegionCoprocessor, + RegionServerCoprocessor, and WALCoprocessor. Coprocessor.State - Enum in org.apache.hadoop.hbase @@ -19241,12 +19216,6 @@ createKeyOnlyCell(Cell) - Method in class org.apache.hadoop.hbase.filter.KeyOnlyFilter -createKeyValueFromKey(byte[]) - Static method in class org.apache.hadoop.hbase.KeyValue - -createKeyValueFromKey(ByteBuffer) - Static method in class org.apache.hadoop.hbase.KeyValue - -createKeyValueFromKey(byte[], int, int) - Static method in class org.apache.hadoop.hbase.KeyValue - createKeyValueFromKey(byte[]) - Static method in class org.apache.hadoop.hbase.KeyValueUtil createKeyValueFromKey(ByteBuffer) - Static method in class org.apache.hadoop.hbase.KeyValueUtil @@ -35127,12 +35096,6 @@ getCompactSplitThread() - Method in class org.apache.hadoop.hbase.regionserver.HRegionServer -getComparator() - Method in class org.apache.hadoop.hbase.client.RegionInfoBuilder.MutableRegionInfo - -Deprecated. -Use Region#getCellComparator(). deprecated for hbase 2.0, remove for hbase 3.0 - - getComparator() - Method in class org.apache.hadoop.hbase.filter.CompareFilter getComparator() - Method in class org.apache.hadoop.hbase.filter.SingleColumnValueFilter @@ -39380,11 +39343,6 @@ Deprecated. The HFileV2 file format's trailer contains this class name. -getLegacyKeyComparatorName() - Method in class org.apache.hadoop.hbase.KeyValue.RawBytesComparator - -Deprecated. -The HFileV2 file format's trailer contains this class name. - getLength(byte[], int) - Static method in class org.apache.hadoop.hbase.ArrayBackedTag getLength() - Method in class org.apache.hadoop.hbase.io.hfile.bucket.BucketCache.BucketEntry @@ -45808,13 +45766,6 @@ getRowByteBuffer() - Method in class org.apache.hadoop.hbase.io.encoding.BufferedDataBlockEncoder.OffheapDecodedCell
[02/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.html index 26125e3..eb6a00d 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.html @@ -28,3193 +28,3241 @@ 020 021import static org.apache.hadoop.hbase.HConstants.EMPTY_BYTE_ARRAY; 022import static org.apache.hadoop.hbase.Tag.TAG_LENGTH_SIZE; -023 -024import java.io.DataOutputStream; -025import java.io.IOException; -026import java.io.OutputStream; -027import java.math.BigDecimal; -028import java.nio.ByteBuffer; -029import java.util.ArrayList; -030import java.util.Arrays; -031import java.util.Iterator; -032import java.util.List; -033import java.util.Map.Entry; -034import java.util.NavigableMap; -035 -036import org.apache.hadoop.hbase.KeyValue.Type; -037import org.apache.yetus.audience.InterfaceAudience; -038import org.apache.yetus.audience.InterfaceAudience.Private; -039import org.apache.hadoop.hbase.io.HeapSize; -040import org.apache.hadoop.hbase.io.TagCompressionContext; -041import org.apache.hadoop.hbase.io.util.Dictionary; -042import org.apache.hadoop.hbase.io.util.StreamUtils; -043import org.apache.hadoop.hbase.util.ByteBufferUtils; -044import org.apache.hadoop.hbase.util.ByteRange; -045import org.apache.hadoop.hbase.util.Bytes; -046import org.apache.hadoop.hbase.util.ClassSize; -047 -048/** -049 * Utility methods helpful slinging {@link Cell} instances. -050 * Some methods below are for internal use only and are marked InterfaceAudience.Private at the -051 * method level. -052 */ -053@InterfaceAudience.Public -054public final class CellUtil { -055 -056 /** -057 * Private constructor to keep this class from being instantiated. -058 */ -059 private CellUtil(){} -060 -061 /*** ByteRange ***/ -062 -063 public static ByteRange fillRowRange(Cell cell, ByteRange range) { -064return range.set(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()); -065 } -066 -067 public static ByteRange fillFamilyRange(Cell cell, ByteRange range) { -068return range.set(cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength()); -069 } -070 -071 public static ByteRange fillQualifierRange(Cell cell, ByteRange range) { -072return range.set(cell.getQualifierArray(), cell.getQualifierOffset(), -073 cell.getQualifierLength()); -074 } -075 -076 public static ByteRange fillValueRange(Cell cell, ByteRange range) { -077return range.set(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength()); -078 } -079 -080 public static ByteRange fillTagRange(Cell cell, ByteRange range) { -081return range.set(cell.getTagsArray(), cell.getTagsOffset(), cell.getTagsLength()); -082 } -083 -084 /* get individual arrays for tests / -085 -086 public static byte[] cloneRow(Cell cell){ -087byte[] output = new byte[cell.getRowLength()]; -088copyRowTo(cell, output, 0); -089return output; -090 } -091 -092 public static byte[] cloneFamily(Cell cell){ -093byte[] output = new byte[cell.getFamilyLength()]; -094copyFamilyTo(cell, output, 0); -095return output; -096 } -097 -098 public static byte[] cloneQualifier(Cell cell){ -099byte[] output = new byte[cell.getQualifierLength()]; -100copyQualifierTo(cell, output, 0); -101return output; -102 } -103 -104 public static byte[] cloneValue(Cell cell){ -105byte[] output = new byte[cell.getValueLength()]; -106copyValueTo(cell, output, 0); -107return output; -108 } -109 -110 public static byte[] cloneTags(Cell cell) { -111byte[] output = new byte[cell.getTagsLength()]; -112copyTagTo(cell, output, 0); -113return output; -114 } -115 -116 /** -117 * Returns tag value in a new byte array. If server-side, use -118 * {@link Tag#getValueArray()} with appropriate {@link Tag#getValueOffset()} and -119 * {@link Tag#getValueLength()} instead to save on allocations. -120 * @param cell -121 * @return tag value in a new byte array. -122 */ -123 public static byte[] getTagArray(Cell cell){ -124byte[] output = new byte[cell.getTagsLength()]; -125copyTagTo(cell, output, 0); -126return output; -127 } -128 -129 -130 / copyTo **/ +023import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIMITER; +024import static org.apache.hadoop.hbase.KeyValue.getDelimiter; +025import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIM_ARRAY; +026 +027import java.io.DataOutputStream; +028import java.io.IOException; +029import java.io.OutputStream; +030import java.math.BigDecimal; +031import
[26/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.html b/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.html index 9cb328e..88ec282 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.html @@ -779,7 +779,7 @@ extends regionObserverGetter -privateCoprocessorHost.ObserverGetterRegionCoprocessor,RegionObserver regionObserverGetter +privateCoprocessorHost.ObserverGetterRegionCoprocessor,RegionObserver regionObserverGetter @@ -788,7 +788,7 @@ extends endpointObserverGetter -privateCoprocessorHost.ObserverGetterRegionCoprocessor,EndpointObserver endpointObserverGetter +privateCoprocessorHost.ObserverGetterRegionCoprocessor,EndpointObserver endpointObserverGetter @@ -888,7 +888,7 @@ extends checkAndGetInstance -publicRegionCoprocessorcheckAndGetInstance(http://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true; title="class or interface in java.lang">Class?implClass) +publicRegionCoprocessorcheckAndGetInstance(http://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true; title="class or interface in java.lang">Class?implClass) throws http://docs.oracle.com/javase/8/docs/api/java/lang/InstantiationException.html?is-external=true; title="class or interface in java.lang">InstantiationException, http://docs.oracle.com/javase/8/docs/api/java/lang/IllegalAccessException.html?is-external=true; title="class or interface in java.lang">IllegalAccessException Description copied from class:CoprocessorHost @@ -912,7 +912,7 @@ extends preOpen -publicvoidpreOpen() +publicvoidpreOpen() throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Invoked before a region open. @@ -927,7 +927,7 @@ extends postOpen -publicvoidpostOpen() +publicvoidpostOpen() Invoked after a region open @@ -937,7 +937,7 @@ extends postLogReplay -publicvoidpostLogReplay() +publicvoidpostLogReplay() Invoked after log replay on region @@ -947,7 +947,7 @@ extends preClose -publicvoidpreClose(booleanabortRequested) +publicvoidpreClose(booleanabortRequested) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Invoked before a region is closed @@ -964,7 +964,7 @@ extends postClose -publicvoidpostClose(booleanabortRequested) +publicvoidpostClose(booleanabortRequested) Invoked after a region is closed Parameters: @@ -978,7 +978,7 @@ extends preCompactScannerOpen -publicInternalScannerpreCompactScannerOpen(HStorestore, +publicInternalScannerpreCompactScannerOpen(HStorestore, http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListStoreFileScannerscanners, ScanTypescanType, longearliestPutTs, @@ -1001,7 +1001,7 @@ extends preCompactSelection -publicbooleanpreCompactSelection(HStorestore, +publicbooleanpreCompactSelection(HStorestore, http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListHStoreFilecandidates, CompactionLifeCycleTrackertracker, Useruser) @@ -1026,7 +1026,7 @@ extends postCompactSelection -publicvoidpostCompactSelection(HStorestore, +publicvoidpostCompactSelection(HStorestore, org.apache.hadoop.hbase.shaded.com.google.common.collect.ImmutableListHStoreFileselected, CompactionLifeCycleTrackertracker, Useruser) @@ -1049,7 +1049,7 @@ extends preCompact -publicInternalScannerpreCompact(HStorestore, +publicInternalScannerpreCompact(HStorestore, InternalScannerscanner, ScanTypescanType, CompactionLifeCycleTrackertracker, @@ -1073,7 +1073,7 @@ extends postCompact -publicvoidpostCompact(HStorestore, +publicvoidpostCompact(HStorestore, HStoreFileresultFile, CompactionLifeCycleTrackertracker, Useruser) @@ -1095,7 +1095,7 @@ extends preFlush -publicInternalScannerpreFlush(HStorestore,
[34/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/NoTagsKeyValue.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/NoTagsKeyValue.html b/devapidocs/org/apache/hadoop/hbase/NoTagsKeyValue.html index 4920e75..ad24657 100644 --- a/devapidocs/org/apache/hadoop/hbase/NoTagsKeyValue.html +++ b/devapidocs/org/apache/hadoop/hbase/NoTagsKeyValue.html @@ -139,7 +139,7 @@ extends KeyValue -KeyValue.KeyOnlyKeyValue, KeyValue.KVComparator, KeyValue.MetaComparator, KeyValue.RawBytesComparator, KeyValue.RowOnlyComparator, KeyValue.SamePrefixComparatorT, KeyValue.Type +KeyValue.KeyOnlyKeyValue, KeyValue.KVComparator, KeyValue.MetaComparator, KeyValue.SamePrefixComparatorT, KeyValue.Type @@ -154,7 +154,7 @@ extends KeyValue -bytes, COLUMN_FAMILY_DELIM_ARRAY, COLUMN_FAMILY_DELIMITER, COMPARATOR, FAMILY_LENGTH_SIZE, FIXED_OVERHEAD, KEY_INFRASTRUCTURE_SIZE, KEY_LENGTH_SIZE, KEYVALUE_INFRASTRUCTURE_SIZE, KEYVALUE_WITH_TAGS_INFRASTRUCTURE_SIZE, length, LOWESTKEY, META_COMPARATOR, offset, RAW_COMPARATOR, ROW_KEY_OFFSET, ROW_LENGTH_SIZE, ROW_OFFSET, TAGS_LENGTH_SIZE, TIMESTAMP_SIZE, TIMESTAMP_TYPE_SIZE, TYPE_SIZE +bytes, COLUMN_FAMILY_DELIM_ARRAY, COLUMN_FAMILY_DELIMITER, COMPARATOR, FAMILY_LENGTH_SIZE, FIXED_OVERHEAD, KEY_INFRASTRUCTURE_SIZE, KEY_LENGTH_SIZE, KEYVALUE_INFRASTRUCTURE_SIZE, KEYVALUE_WITH_TAGS_INFRASTRUCTURE_SIZE, length, LOWESTKEY, META_COMPARATOR, offset, ROW_KEY_OFFSET, ROW_LENGTH_SIZE, ROW_OFFSET, TAGS_LENGTH_SIZE, TIMESTAMP_SIZE, TIMESTAMP_TYPE_SIZE, TYPE_SIZE @@ -225,7 +225,7 @@ extends KeyValue -checkParameters, clone, cloneAndAddTags, create, create, createKeyOnly, createKeyValueFromKey, createKeyValueFromKey, createKeyValueFromKey, equals, getBuffer, getDelimiter, getDelimiterInReverse, getFamilyArray, getFamilyLength, getFamilyLength, getFamilyOffset, getKey, getKeyDataStructureSize, getKeyLength, getKeyOffset, getKeyString, getKeyValueDataStructureSize, getKeyValueDataStructureSize, getKeyValueDataStructureSize, getLength, getOffset, getQualifierArray, getQualifierLength, getQualifierOffset, getRowArray, getRowLength, getRowOffset, getSequenceId, getTags, getTagsArray, getTagsOffset, getTimestamp, getTimestamp, getTimestampOffset, getType, getTypeByte, getValueArray, getValueLength, getValueOffset, hashCode, heapSize, humanReadableTimestamp, iscreate, isDelete, isDelete, isLatestTimestamp, keyToString, keyToString, makeColumn, oswrite, parseColumn, setSequenceId, setTimestamp, setTimestamp, shallowCopy, toString, toStringMap, updateLatestStamp, write, write, writeByteArray +checkParameters, clone, create, create, createKeyOnly, equals, getBuffer, getDelimiter, getDelimiterInReverse, getFamilyArray, getFamilyLength, getFamilyLength, getFamilyOffset, getKey, getKeyDataStructureSize, getKeyLength, getKeyOffset, getKeyString, getKeyValueDataStructureSize, getKeyValueDataStructureSize, getKeyValueDataStructureSize, getLength, getOffset, getQualifierArray, getQualifierLength, getQualifierOffset, getRowArray, getRowLength, get RowOffset, getSequenceId, getTags, getTagsArray, getTagsOffset, getTimestamp, getTimestamp, getTimestampOffset, getTypeByte, getValueArray, getValueLength, getValueOffset, hashCode, heapSize, humanReadableTimestamp, isLatestTimestamp, keyToString, keyToString, oswrite, setSequenceId, setTimestamp, < a href="../../../../org/apache/hadoop/hbase/KeyValue.html#setTimestamp-long-">setTimestamp, shallowCopy, toString, toStringMap, updateLatestStamp, write, write, writeByteArray http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/SizeCachedKeyValue.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/SizeCachedKeyValue.html b/devapidocs/org/apache/hadoop/hbase/SizeCachedKeyValue.html index d03fac9..0fe1106 100644 --- a/devapidocs/org/apache/hadoop/hbase/SizeCachedKeyValue.html +++ b/devapidocs/org/apache/hadoop/hbase/SizeCachedKeyValue.html @@ -147,7 +147,7 @@ extends KeyValue -KeyValue.KeyOnlyKeyValue, KeyValue.KVComparator, KeyValue.MetaComparator, KeyValue.RawBytesComparator, KeyValue.RowOnlyComparator, KeyValue.SamePrefixComparatorT, KeyValue.Type +KeyValue.KeyOnlyKeyValue, KeyValue.KVComparator, KeyValue.MetaComparator, KeyValue.SamePrefixComparatorT, KeyValue.Type @@ -181,7 +181,7 @@ extends KeyValue -bytes, COLUMN_FAMILY_DELIM_ARRAY, COLUMN_FAMILY_DELIMITER, COMPARATOR, FAMILY_LENGTH_SIZE, KEY_INFRASTRUCTURE_SIZE, KEY_LENGTH_SIZE, KEYVALUE_INFRASTRUCTURE_SIZE, KEYVALUE_WITH_TAGS_INFRASTRUCTURE_SIZE, length, LOWESTKEY, META_COMPARATOR, offset, RAW_COMPARATOR, ROW_KEY_OFFSET, ROW_LENGTH_SIZE, ROW_OFFSET, TAGS_LENGTH_SIZE, TIMESTAMP_SIZE,
[09/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowCell.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowCell.html index 26125e3..eb6a00d 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowCell.html @@ -28,3193 +28,3241 @@ 020 021import static org.apache.hadoop.hbase.HConstants.EMPTY_BYTE_ARRAY; 022import static org.apache.hadoop.hbase.Tag.TAG_LENGTH_SIZE; -023 -024import java.io.DataOutputStream; -025import java.io.IOException; -026import java.io.OutputStream; -027import java.math.BigDecimal; -028import java.nio.ByteBuffer; -029import java.util.ArrayList; -030import java.util.Arrays; -031import java.util.Iterator; -032import java.util.List; -033import java.util.Map.Entry; -034import java.util.NavigableMap; -035 -036import org.apache.hadoop.hbase.KeyValue.Type; -037import org.apache.yetus.audience.InterfaceAudience; -038import org.apache.yetus.audience.InterfaceAudience.Private; -039import org.apache.hadoop.hbase.io.HeapSize; -040import org.apache.hadoop.hbase.io.TagCompressionContext; -041import org.apache.hadoop.hbase.io.util.Dictionary; -042import org.apache.hadoop.hbase.io.util.StreamUtils; -043import org.apache.hadoop.hbase.util.ByteBufferUtils; -044import org.apache.hadoop.hbase.util.ByteRange; -045import org.apache.hadoop.hbase.util.Bytes; -046import org.apache.hadoop.hbase.util.ClassSize; -047 -048/** -049 * Utility methods helpful slinging {@link Cell} instances. -050 * Some methods below are for internal use only and are marked InterfaceAudience.Private at the -051 * method level. -052 */ -053@InterfaceAudience.Public -054public final class CellUtil { -055 -056 /** -057 * Private constructor to keep this class from being instantiated. -058 */ -059 private CellUtil(){} -060 -061 /*** ByteRange ***/ -062 -063 public static ByteRange fillRowRange(Cell cell, ByteRange range) { -064return range.set(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()); -065 } -066 -067 public static ByteRange fillFamilyRange(Cell cell, ByteRange range) { -068return range.set(cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength()); -069 } -070 -071 public static ByteRange fillQualifierRange(Cell cell, ByteRange range) { -072return range.set(cell.getQualifierArray(), cell.getQualifierOffset(), -073 cell.getQualifierLength()); -074 } -075 -076 public static ByteRange fillValueRange(Cell cell, ByteRange range) { -077return range.set(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength()); -078 } -079 -080 public static ByteRange fillTagRange(Cell cell, ByteRange range) { -081return range.set(cell.getTagsArray(), cell.getTagsOffset(), cell.getTagsLength()); -082 } -083 -084 /* get individual arrays for tests / -085 -086 public static byte[] cloneRow(Cell cell){ -087byte[] output = new byte[cell.getRowLength()]; -088copyRowTo(cell, output, 0); -089return output; -090 } -091 -092 public static byte[] cloneFamily(Cell cell){ -093byte[] output = new byte[cell.getFamilyLength()]; -094copyFamilyTo(cell, output, 0); -095return output; -096 } -097 -098 public static byte[] cloneQualifier(Cell cell){ -099byte[] output = new byte[cell.getQualifierLength()]; -100copyQualifierTo(cell, output, 0); -101return output; -102 } -103 -104 public static byte[] cloneValue(Cell cell){ -105byte[] output = new byte[cell.getValueLength()]; -106copyValueTo(cell, output, 0); -107return output; -108 } -109 -110 public static byte[] cloneTags(Cell cell) { -111byte[] output = new byte[cell.getTagsLength()]; -112copyTagTo(cell, output, 0); -113return output; -114 } -115 -116 /** -117 * Returns tag value in a new byte array. If server-side, use -118 * {@link Tag#getValueArray()} with appropriate {@link Tag#getValueOffset()} and -119 * {@link Tag#getValueLength()} instead to save on allocations. -120 * @param cell -121 * @return tag value in a new byte array. -122 */ -123 public static byte[] getTagArray(Cell cell){ -124byte[] output = new byte[cell.getTagsLength()]; -125copyTagTo(cell, output, 0); -126return output; -127 } -128 -129 -130 / copyTo **/ +023import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIMITER; +024import static org.apache.hadoop.hbase.KeyValue.getDelimiter; +025import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIM_ARRAY; +026 +027import java.io.DataOutputStream; +028import java.io.IOException; +029import
[07/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowColCell.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowColCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowColCell.html index 26125e3..eb6a00d 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowColCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowColCell.html @@ -28,3193 +28,3241 @@ 020 021import static org.apache.hadoop.hbase.HConstants.EMPTY_BYTE_ARRAY; 022import static org.apache.hadoop.hbase.Tag.TAG_LENGTH_SIZE; -023 -024import java.io.DataOutputStream; -025import java.io.IOException; -026import java.io.OutputStream; -027import java.math.BigDecimal; -028import java.nio.ByteBuffer; -029import java.util.ArrayList; -030import java.util.Arrays; -031import java.util.Iterator; -032import java.util.List; -033import java.util.Map.Entry; -034import java.util.NavigableMap; -035 -036import org.apache.hadoop.hbase.KeyValue.Type; -037import org.apache.yetus.audience.InterfaceAudience; -038import org.apache.yetus.audience.InterfaceAudience.Private; -039import org.apache.hadoop.hbase.io.HeapSize; -040import org.apache.hadoop.hbase.io.TagCompressionContext; -041import org.apache.hadoop.hbase.io.util.Dictionary; -042import org.apache.hadoop.hbase.io.util.StreamUtils; -043import org.apache.hadoop.hbase.util.ByteBufferUtils; -044import org.apache.hadoop.hbase.util.ByteRange; -045import org.apache.hadoop.hbase.util.Bytes; -046import org.apache.hadoop.hbase.util.ClassSize; -047 -048/** -049 * Utility methods helpful slinging {@link Cell} instances. -050 * Some methods below are for internal use only and are marked InterfaceAudience.Private at the -051 * method level. -052 */ -053@InterfaceAudience.Public -054public final class CellUtil { -055 -056 /** -057 * Private constructor to keep this class from being instantiated. -058 */ -059 private CellUtil(){} -060 -061 /*** ByteRange ***/ -062 -063 public static ByteRange fillRowRange(Cell cell, ByteRange range) { -064return range.set(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()); -065 } -066 -067 public static ByteRange fillFamilyRange(Cell cell, ByteRange range) { -068return range.set(cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength()); -069 } -070 -071 public static ByteRange fillQualifierRange(Cell cell, ByteRange range) { -072return range.set(cell.getQualifierArray(), cell.getQualifierOffset(), -073 cell.getQualifierLength()); -074 } -075 -076 public static ByteRange fillValueRange(Cell cell, ByteRange range) { -077return range.set(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength()); -078 } -079 -080 public static ByteRange fillTagRange(Cell cell, ByteRange range) { -081return range.set(cell.getTagsArray(), cell.getTagsOffset(), cell.getTagsLength()); -082 } -083 -084 /* get individual arrays for tests / -085 -086 public static byte[] cloneRow(Cell cell){ -087byte[] output = new byte[cell.getRowLength()]; -088copyRowTo(cell, output, 0); -089return output; -090 } -091 -092 public static byte[] cloneFamily(Cell cell){ -093byte[] output = new byte[cell.getFamilyLength()]; -094copyFamilyTo(cell, output, 0); -095return output; -096 } -097 -098 public static byte[] cloneQualifier(Cell cell){ -099byte[] output = new byte[cell.getQualifierLength()]; -100copyQualifierTo(cell, output, 0); -101return output; -102 } -103 -104 public static byte[] cloneValue(Cell cell){ -105byte[] output = new byte[cell.getValueLength()]; -106copyValueTo(cell, output, 0); -107return output; -108 } -109 -110 public static byte[] cloneTags(Cell cell) { -111byte[] output = new byte[cell.getTagsLength()]; -112copyTagTo(cell, output, 0); -113return output; -114 } -115 -116 /** -117 * Returns tag value in a new byte array. If server-side, use -118 * {@link Tag#getValueArray()} with appropriate {@link Tag#getValueOffset()} and -119 * {@link Tag#getValueLength()} instead to save on allocations. -120 * @param cell -121 * @return tag value in a new byte array. -122 */ -123 public static byte[] getTagArray(Cell cell){ -124byte[] output = new byte[cell.getTagsLength()]; -125copyTagTo(cell, output, 0); -126return output; -127 } -128 -129 -130 / copyTo **/ +023import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIMITER; +024import static org.apache.hadoop.hbase.KeyValue.getDelimiter; +025import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIM_ARRAY; +026 +027import java.io.DataOutputStream; +028import java.io.IOException;
[31/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/class-use/Cell.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/Cell.html b/devapidocs/org/apache/hadoop/hbase/class-use/Cell.html index aefca3e..ed5695d 100644 --- a/devapidocs/org/apache/hadoop/hbase/class-use/Cell.html +++ b/devapidocs/org/apache/hadoop/hbase/class-use/Cell.html @@ -715,35 +715,28 @@ service. -static KeyValue -KeyValue.cloneAndAddTags(Cellc, - http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListTagnewTags) -Create a new KeyValue by copying existing cell and adding new tags - - - static byte[] CellUtil.cloneFamily(Cellcell) - + static byte[] CellUtil.cloneQualifier(Cellcell) - + static byte[] CellUtil.cloneRow(Cellcell) get individual arrays for tests - + static byte[] CellUtil.cloneTags(Cellcell) - + static byte[] CellUtil.cloneValue(Cellcell) - + int CellComparator.compare(Cellleft, byte[]key, @@ -755,12 +748,12 @@ service. If the KeyValue (Cell's) serialization format changes this method cannot be used. - + int CellComparator.compare(Cella, Cellb) - + int KeyValue.MetaComparator.compare(Cellleft, Cellright) @@ -769,7 +762,7 @@ service. table. - + int KeyValue.KVComparator.compare(Cellleft, Cellright) @@ -778,13 +771,6 @@ service. rowkey, colfam/qual, timestamp, type, mvcc - -int -KeyValue.RawBytesComparator.compare(Cellleft, - Cellright) -Deprecated. - - private int CellComparator.compare(Cella, @@ -892,41 +878,34 @@ service. -int -KeyValue.RawBytesComparator.compareOnlyKeyPortion(Cellleft, - Cellright) -Deprecated. - - - static int CellComparator.compareQualifier(Cellcell, ByteArrayComparablecomparator) Compare cell's qualifier against given comparator - + static int CellComparator.compareQualifiers(Cellleft, byte[]right, intrOffset, intrLength) - + static int CellComparator.compareQualifiers(Cellleft, Cellright) Compare the qualifiers part of the left and right cells. - + static int CellComparator.compareRow(Cellcell, ByteArrayComparablecomparator) Compare cell's row against given comparator - + protected int KeyValue.MetaComparator.compareRowKey(Celll, Cellr) @@ -934,7 +913,7 @@ service. Override the row key comparison to parse and compare the meta row key parts. - + protected int KeyValue.KVComparator.compareRowKey(Cellleft, Cellright) @@ -942,7 +921,7 @@ service. Compares the only the user specified portion of a Key. - + int CellComparator.compareRows(Cellleft, byte[]right, @@ -952,54 +931,54 @@ service. stopRow in Scan. - + int CellComparator.MetaCellComparator.compareRows(Cellleft, byte[]right, introffset, intrlength) - + int CellComparator.compareRows(Cellleft, Cellright) Compares the rows of the left and right cell. - + int CellComparator.MetaCellComparator.compareRows(Cellleft, Cellright) - + int KeyValue.KVComparator.compareRows(Cellleft, Cellright) Deprecated. - + static int CellComparator.compareTimestamps(Cellleft, Cellright) Compares cell's timestamps in DESCENDING order. - + int KeyValue.KVComparator.compareTimestamps(Cellleft, Cellright) Deprecated. - + static int CellComparator.compareValue(Cellcell, ByteArrayComparablecomparator) Compare cell's value against given comparator - + private int CellComparator.compareWithoutRow(Cellleft, byte[]right, @@ -1010,30 +989,30 @@ service. except the row). - + static int CellComparator.compareWithoutRow(Cellleft, Cellright) - + static void CellUtil.compressFamily(http://docs.oracle.com/javase/8/docs/api/java/io/OutputStream.html?is-external=true; title="class or interface in java.io">OutputStreamout, Cellcell, Dictionarydict) - + static void CellUtil.compressQualifier(http://docs.oracle.com/javase/8/docs/api/java/io/OutputStream.html?is-external=true; title="class or interface in java.io">OutputStreamout, Cellcell, Dictionarydict) - + static void CellUtil.compressRow(http://docs.oracle.com/javase/8/docs/api/java/io/OutputStream.html?is-external=true; title="class or interface in java.io">OutputStreamout, Cellcell, Dictionarydict) - + static void CellUtil.compressTags(http://docs.oracle.com/javase/8/docs/api/java/io/OutputStream.html?is-external=true; title="class or interface in java.io">OutputStreamout, Cellcell, @@ -1041,48
[40/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/CellUtil.LastOnRowColByteBufferCell.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/CellUtil.LastOnRowColByteBufferCell.html b/devapidocs/org/apache/hadoop/hbase/CellUtil.LastOnRowColByteBufferCell.html index 60ba786..062188d 100644 --- a/devapidocs/org/apache/hadoop/hbase/CellUtil.LastOnRowColByteBufferCell.html +++ b/devapidocs/org/apache/hadoop/hbase/CellUtil.LastOnRowColByteBufferCell.html @@ -133,7 +133,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private -private static class CellUtil.LastOnRowColByteBufferCell +private static class CellUtil.LastOnRowColByteBufferCell extends CellUtil.LastOnRowByteBufferCell @@ -283,7 +283,7 @@ extends fBuffer -private finalhttp://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true; title="class or interface in java.nio">ByteBuffer fBuffer +private finalhttp://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true; title="class or interface in java.nio">ByteBuffer fBuffer @@ -292,7 +292,7 @@ extends foffset -private finalint foffset +private finalint foffset @@ -301,7 +301,7 @@ extends flength -private finalbyte flength +private finalbyte flength @@ -310,7 +310,7 @@ extends qBuffer -private finalhttp://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true; title="class or interface in java.nio">ByteBuffer qBuffer +private finalhttp://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true; title="class or interface in java.nio">ByteBuffer qBuffer @@ -319,7 +319,7 @@ extends qoffset -private finalint qoffset +private finalint qoffset @@ -328,7 +328,7 @@ extends qlength -private finalint qlength +private finalint qlength @@ -345,7 +345,7 @@ extends LastOnRowColByteBufferCell -publicLastOnRowColByteBufferCell(http://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true; title="class or interface in java.nio">ByteBufferrBuffer, +publicLastOnRowColByteBufferCell(http://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true; title="class or interface in java.nio">ByteBufferrBuffer, introffset, shortrlength, http://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true; title="class or interface in java.nio">ByteBufferfBuffer, @@ -370,7 +370,7 @@ extends getFamilyByteBuffer -publichttp://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true; title="class or interface in java.nio">ByteBuffergetFamilyByteBuffer() +publichttp://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true; title="class or interface in java.nio">ByteBuffergetFamilyByteBuffer() Overrides: getFamilyByteBufferin classCellUtil.EmptyByteBufferCell @@ -385,7 +385,7 @@ extends getFamilyPosition -publicintgetFamilyPosition() +publicintgetFamilyPosition() Overrides: getFamilyPositionin classCellUtil.EmptyByteBufferCell @@ -400,7 +400,7 @@ extends getFamilyLength -publicbytegetFamilyLength() +publicbytegetFamilyLength() Specified by: getFamilyLengthin interfaceCell @@ -417,7 +417,7 @@ extends getQualifierByteBuffer -publichttp://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true; title="class or interface in java.nio">ByteBuffergetQualifierByteBuffer() +publichttp://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true; title="class or interface in java.nio">ByteBuffergetQualifierByteBuffer() Overrides: getQualifierByteBufferin classCellUtil.EmptyByteBufferCell @@ -432,7 +432,7 @@ extends getQualifierPosition -publicintgetQualifierPosition() +publicintgetQualifierPosition() Overrides: getQualifierPositionin classCellUtil.EmptyByteBufferCell @@ -447,7 +447,7 @@ extends getQualifierLength -publicintgetQualifierLength() +publicintgetQualifierLength() Specified by: getQualifierLengthin interfaceCell http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/CellUtil.LastOnRowColCell.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/CellUtil.LastOnRowColCell.html b/devapidocs/org/apache/hadoop/hbase/CellUtil.LastOnRowColCell.html index 6e97a73..100f68d 100644 --- a/devapidocs/org/apache/hadoop/hbase/CellUtil.LastOnRowColCell.html +++ b/devapidocs/org/apache/hadoop/hbase/CellUtil.LastOnRowColCell.html @@ -128,7 +128,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private -private static class CellUtil.LastOnRowColCell +private static class CellUtil.LastOnRowColCell extends CellUtil.LastOnRowCell @@ -283,7
[49/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/apidocs/org/apache/hadoop/hbase/CellUtil.html -- diff --git a/apidocs/org/apache/hadoop/hbase/CellUtil.html b/apidocs/org/apache/hadoop/hbase/CellUtil.html index c5bbc4d..76de3ec 100644 --- a/apidocs/org/apache/hadoop/hbase/CellUtil.html +++ b/apidocs/org/apache/hadoop/hbase/CellUtil.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":41,"i17":41,"i18":41,"i19":41,"i20":41,"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,"i34":9,"i35":9,"i36":9,"i37":9,"i38":9,"i39":9,"i40":9,"i41":9,"i42":9,"i43":9,"i44":9,"i45":9,"i46":9,"i47":9,"i48":9,"i49":9,"i50":9,"i51":9,"i52":9,"i53":9,"i54":9,"i55":9,"i56":41,"i57":9,"i58":9,"i59":9,"i60":9,"i61":9,"i62":9,"i63":9,"i64":9,"i65":9,"i66":9,"i67":9,"i68":9,"i69":9,"i70":9,"i71":9,"i72":9,"i73":9,"i74":9,"i75":9,"i76":9,"i77":9,"i78":9,"i79":9,"i80":9,"i81":9,"i82":9,"i83":9,"i84":9,"i85":41,"i86":9,"i87":9,"i88":9,"i89":9,"i90":9,"i91":9,"i92":9,"i93":9,"i94":9,"i95":9,"i96":41,"i97":9,"i98":9,"i99":9,"i100":9,"i101":9,"i102":9,"i103":9,"i104":9,"i105":9,"i106":9,"i107":9,"i108":9,"i109":9,"i110":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":41,"i17":41,"i18":41,"i19":41,"i20":41,"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,"i34":9,"i35":9,"i36":9,"i37":9,"i38":9,"i39":9,"i40":9,"i41":9,"i42":9,"i43":9,"i44":9,"i45":9,"i46":9,"i47":9,"i48":9,"i49":9,"i50":9,"i51":9,"i52":9,"i53":9,"i54":9,"i55":9,"i56":41,"i57":9,"i58":9,"i59":9,"i60":9,"i61":9,"i62":9,"i63":9,"i64":9,"i65":9,"i66":9,"i67":9,"i68":9,"i69":9,"i70":9,"i71":9,"i72":9,"i73":9,"i74":9,"i75":9,"i76":9,"i77":9,"i78":9,"i79":9,"i80":9,"i81":9,"i82":9,"i83":9,"i84":9,"i85":9,"i86":41,"i87":9,"i88":9,"i89":9,"i90":9,"i91":9,"i92":9,"i93":9,"i94":9,"i95":9,"i96":9,"i97":9,"i98":41,"i99":9,"i100":9,"i101":9,"i102":9,"i103":9,"i104":9,"i105":9,"i106":9,"i107":9,"i108":9,"i109":9,"i110":9,"i111":9,"i112":9}; var tabs = {65535:["t0","All Methods"],1:["t1","Static Methods"],8:["t4","Concrete Methods"],32:["t6","Deprecated Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -110,7 +110,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Public -public final class CellUtil +public final class CellUtil extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object Utility methods helpful slinging Cell instances. Some methods below are for internal use only and are marked InterfaceAudience.Private at the @@ -590,12 +590,19 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? isDeleteType(Cellcell) +static byte[] +makeColumn(byte[]family, + byte[]qualifier) +Makes a column in family:qualifier form from separate byte arrays. + + + static boolean matchingColumn(Cellleft, byte[]fam, byte[]qual) - + static boolean matchingColumn(Cellleft, byte[]fam, @@ -605,29 +612,29 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? intqoffset, intqlength) - + static boolean matchingColumn(Cellleft, Cellright) - + static boolean matchingFamily(Cellleft, byte[]buf) - + static boolean matchingFamily(Cellleft, byte[]buf, intoffset, intlength) - + static boolean matchingFamily(Cellleft, Cellright) - + static boolean matchingQualifier(Cellleft, byte[]buf) @@ -635,7 +642,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? byte[] are equal - + static boolean matchingQualifier(Cellleft, byte[]buf, @@ -645,24 +652,24 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? byte[] are equal - + static boolean matchingQualifier(Cellleft, Cellright) - + static boolean matchingRow(Cellleft, byte[]buf) - + static boolean matchingRow(Cellleft, byte[]buf, intoffset, intlength) - + static boolean matchingRow(Cellleft, Cellright) @@ -672,48 +679,48 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? - + static boolean matchingRowColumn(Cellleft, Cellright) Compares the row and column of two keyvalues for equality - + static boolean matchingRows(Cellleft, Cellright) Compares the row of two keyvalues for equality - + static boolean matchingTimestamp(Cella,
[43/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/checkstyle.rss -- diff --git a/checkstyle.rss b/checkstyle.rss index 0dcc4f4..42df8bd 100644 --- a/checkstyle.rss +++ b/checkstyle.rss @@ -26,7 +26,7 @@ under the License. 2007 - 2017 The Apache Software Foundation File: 2051, - Errors: 13704, + Errors: 13690, Warnings: 0, Infos: 0 @@ -377,7 +377,7 @@ under the License. 0 - 13 + 14 @@ -783,7 +783,7 @@ under the License. 0 - 56 + 55 @@ -1329,7 +1329,7 @@ under the License. 0 - 21 + 18 @@ -3961,7 +3961,7 @@ under the License. 0 - 6 + 7 @@ -8735,7 +8735,7 @@ under the License. 0 - 99 + 103 @@ -10947,7 +10947,7 @@ under the License. 0 - 4 + 5 @@ -15175,7 +15175,7 @@ under the License. 0 - 39 + 37 @@ -17331,7 +17331,7 @@ under the License. 0 - 22 + 23 @@ -20593,7 +20593,7 @@ under the License. 0 - 136 + 120 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/coc.html -- diff --git a/coc.html b/coc.html index ab28ada..f631625 100644 --- a/coc.html +++ b/coc.html @@ -7,7 +7,7 @@ - + Apache HBase Code of Conduct Policy @@ -380,7 +380,7 @@ email to mailto:priv...@hbase.apache.org;>the priv https://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2017-09-28 + Last Published: 2017-09-29 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/cygwin.html -- diff --git a/cygwin.html b/cygwin.html index 5eff9e2..4ace949 100644 --- a/cygwin.html +++ b/cygwin.html @@ -7,7 +7,7 @@ - + Apache HBase Installing Apache HBase (TM) on Windows using Cygwin @@ -679,7 +679,7 @@ Now your HBase server is running, start coding and build that next https://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2017-09-28 + Last Published: 2017-09-29 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/dependencies.html -- diff --git a/dependencies.html b/dependencies.html index 0249e4c..e844517 100644 --- a/dependencies.html +++ b/dependencies.html @@ -7,7 +7,7 @@ - + Apache HBase Project Dependencies @@ -445,7 +445,7 @@ https://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2017-09-28 + Last Published: 2017-09-29 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/dependency-convergence.html -- diff --git a/dependency-convergence.html b/dependency-convergence.html index 9e1f123..0a9bd58 100644 --- a/dependency-convergence.html +++ b/dependency-convergence.html @@ -7,7 +7,7 @@ - + Apache HBase Reactor Dependency Convergence @@ -820,7 +820,7 @@ https://www.apache.org/;>The Apache Software Foundation. All rights
hbase-site git commit: INFRA-10751 Empty commit
Repository: hbase-site Updated Branches: refs/heads/asf-site aea328beb -> cced62a05 INFRA-10751 Empty commit Project: http://git-wip-us.apache.org/repos/asf/hbase-site/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase-site/commit/cced62a0 Tree: http://git-wip-us.apache.org/repos/asf/hbase-site/tree/cced62a0 Diff: http://git-wip-us.apache.org/repos/asf/hbase-site/diff/cced62a0 Branch: refs/heads/asf-site Commit: cced62a05044f5bdddca79a5ead1e9812527723a Parents: aea328b Author: jenkinsAuthored: Fri Sep 29 15:13:54 2017 + Committer: jenkins Committed: Fri Sep 29 15:13:54 2017 + -- --
[05/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.TagRewriteCell.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.TagRewriteCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.TagRewriteCell.html index 26125e3..eb6a00d 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.TagRewriteCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.TagRewriteCell.html @@ -28,3193 +28,3241 @@ 020 021import static org.apache.hadoop.hbase.HConstants.EMPTY_BYTE_ARRAY; 022import static org.apache.hadoop.hbase.Tag.TAG_LENGTH_SIZE; -023 -024import java.io.DataOutputStream; -025import java.io.IOException; -026import java.io.OutputStream; -027import java.math.BigDecimal; -028import java.nio.ByteBuffer; -029import java.util.ArrayList; -030import java.util.Arrays; -031import java.util.Iterator; -032import java.util.List; -033import java.util.Map.Entry; -034import java.util.NavigableMap; -035 -036import org.apache.hadoop.hbase.KeyValue.Type; -037import org.apache.yetus.audience.InterfaceAudience; -038import org.apache.yetus.audience.InterfaceAudience.Private; -039import org.apache.hadoop.hbase.io.HeapSize; -040import org.apache.hadoop.hbase.io.TagCompressionContext; -041import org.apache.hadoop.hbase.io.util.Dictionary; -042import org.apache.hadoop.hbase.io.util.StreamUtils; -043import org.apache.hadoop.hbase.util.ByteBufferUtils; -044import org.apache.hadoop.hbase.util.ByteRange; -045import org.apache.hadoop.hbase.util.Bytes; -046import org.apache.hadoop.hbase.util.ClassSize; -047 -048/** -049 * Utility methods helpful slinging {@link Cell} instances. -050 * Some methods below are for internal use only and are marked InterfaceAudience.Private at the -051 * method level. -052 */ -053@InterfaceAudience.Public -054public final class CellUtil { -055 -056 /** -057 * Private constructor to keep this class from being instantiated. -058 */ -059 private CellUtil(){} -060 -061 /*** ByteRange ***/ -062 -063 public static ByteRange fillRowRange(Cell cell, ByteRange range) { -064return range.set(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()); -065 } -066 -067 public static ByteRange fillFamilyRange(Cell cell, ByteRange range) { -068return range.set(cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength()); -069 } -070 -071 public static ByteRange fillQualifierRange(Cell cell, ByteRange range) { -072return range.set(cell.getQualifierArray(), cell.getQualifierOffset(), -073 cell.getQualifierLength()); -074 } -075 -076 public static ByteRange fillValueRange(Cell cell, ByteRange range) { -077return range.set(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength()); -078 } -079 -080 public static ByteRange fillTagRange(Cell cell, ByteRange range) { -081return range.set(cell.getTagsArray(), cell.getTagsOffset(), cell.getTagsLength()); -082 } -083 -084 /* get individual arrays for tests / -085 -086 public static byte[] cloneRow(Cell cell){ -087byte[] output = new byte[cell.getRowLength()]; -088copyRowTo(cell, output, 0); -089return output; -090 } -091 -092 public static byte[] cloneFamily(Cell cell){ -093byte[] output = new byte[cell.getFamilyLength()]; -094copyFamilyTo(cell, output, 0); -095return output; -096 } -097 -098 public static byte[] cloneQualifier(Cell cell){ -099byte[] output = new byte[cell.getQualifierLength()]; -100copyQualifierTo(cell, output, 0); -101return output; -102 } -103 -104 public static byte[] cloneValue(Cell cell){ -105byte[] output = new byte[cell.getValueLength()]; -106copyValueTo(cell, output, 0); -107return output; -108 } -109 -110 public static byte[] cloneTags(Cell cell) { -111byte[] output = new byte[cell.getTagsLength()]; -112copyTagTo(cell, output, 0); -113return output; -114 } -115 -116 /** -117 * Returns tag value in a new byte array. If server-side, use -118 * {@link Tag#getValueArray()} with appropriate {@link Tag#getValueOffset()} and -119 * {@link Tag#getValueLength()} instead to save on allocations. -120 * @param cell -121 * @return tag value in a new byte array. -122 */ -123 public static byte[] getTagArray(Cell cell){ -124byte[] output = new byte[cell.getTagsLength()]; -125copyTagTo(cell, output, 0); -126return output; -127 } -128 -129 -130 / copyTo **/ +023import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIMITER; +024import static org.apache.hadoop.hbase.KeyValue.getDelimiter; +025import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIM_ARRAY; +026 +027import java.io.DataOutputStream; +028import java.io.IOException; +029import
[51/51] [partial] hbase-site git commit: Published site at .
Published site at . Project: http://git-wip-us.apache.org/repos/asf/hbase-site/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase-site/commit/aea328be Tree: http://git-wip-us.apache.org/repos/asf/hbase-site/tree/aea328be Diff: http://git-wip-us.apache.org/repos/asf/hbase-site/diff/aea328be Branch: refs/heads/asf-site Commit: aea328beb88f8e2ace47140aad5d9022dd731e3e Parents: d33b6ba Author: jenkinsAuthored: Fri Sep 29 15:13:16 2017 + Committer: jenkins Committed: Fri Sep 29 15:13:16 2017 + -- acid-semantics.html | 4 +- apache_hbase_reference_guide.pdf| 6 +- apidocs/deprecated-list.html| 206 +- apidocs/index-all.html |15 +- apidocs/org/apache/hadoop/hbase/CellUtil.html | 355 +- apidocs/org/apache/hadoop/hbase/TableName.html |76 +- .../hadoop/hbase/mapred/GroupingTableMap.html |18 +- .../hbase/mapreduce/GroupingTableMapper.html|20 +- .../org/apache/hadoop/hbase/CellUtil.html | 6260 +++ .../org/apache/hadoop/hbase/TableName.html | 1022 +- .../hadoop/hbase/mapred/GroupingTableMap.html | 259 +- .../hbase/mapreduce/GroupingTableMapper.html| 297 +- .../hbase/mapreduce/TableInputFormat.html | 4 +- .../hadoop/hbase/rest/client/RemoteHTable.html | 2 +- book.html | 2 +- bulk-loads.html | 4 +- checkstyle-aggregate.html | 16110 - checkstyle.rss |20 +- coc.html| 4 +- cygwin.html | 4 +- dependencies.html | 4 +- dependency-convergence.html | 4 +- dependency-info.html| 4 +- dependency-management.html | 4 +- devapidocs/allclasses-frame.html| 2 - devapidocs/allclasses-noframe.html | 2 - devapidocs/constant-values.html |15 +- devapidocs/deprecated-list.html | 239 +- devapidocs/index-all.html | 191 +- .../hbase/CellUtil.EmptyByteBufferCell.html |58 +- .../apache/hadoop/hbase/CellUtil.EmptyCell.html |38 +- .../CellUtil.FirstOnRowByteBufferCell.html |20 +- .../hadoop/hbase/CellUtil.FirstOnRowCell.html |20 +- .../CellUtil.FirstOnRowColByteBufferCell.html |28 +- .../hbase/CellUtil.FirstOnRowColCell.html |28 +- .../CellUtil.FirstOnRowColTSByteBufferCell.html | 8 +- .../hbase/CellUtil.FirstOnRowColTSCell.html | 8 +- .../CellUtil.FirstOnRowDeleteFamilyCell.html|20 +- .../hbase/CellUtil.LastOnRowByteBufferCell.html |20 +- .../hadoop/hbase/CellUtil.LastOnRowCell.html|20 +- .../CellUtil.LastOnRowColByteBufferCell.html|28 +- .../hadoop/hbase/CellUtil.LastOnRowColCell.html |28 +- .../CellUtil.TagRewriteByteBufferCell.html |82 +- .../hadoop/hbase/CellUtil.TagRewriteCell.html |62 +- ...llUtil.ValueAndTagRewriteByteBufferCell.html |26 +- .../hbase/CellUtil.ValueAndTagRewriteCell.html |26 +- .../org/apache/hadoop/hbase/CellUtil.html | 391 +- .../apache/hadoop/hbase/Coprocessor.State.html |18 +- .../org/apache/hadoop/hbase/Coprocessor.html|56 +- .../org/apache/hadoop/hbase/JMXListener.html| 2 +- .../hadoop/hbase/KeyValue.KVComparator.html |58 +- .../hadoop/hbase/KeyValue.KeyOnlyKeyValue.html |76 +- .../hadoop/hbase/KeyValue.MetaComparator.html |24 +- .../hbase/KeyValue.RawBytesComparator.html | 430 - .../hbase/KeyValue.RowOnlyComparator.html | 331 - .../hbase/KeyValue.SamePrefixComparator.html|10 +- .../org/apache/hadoop/hbase/KeyValue.Type.html |28 +- .../org/apache/hadoop/hbase/KeyValue.html | 674 +- .../org/apache/hadoop/hbase/NoTagsKeyValue.html | 6 +- .../apache/hadoop/hbase/SizeCachedKeyValue.html | 6 +- .../hadoop/hbase/SizeCachedNoTagsKeyValue.html | 6 +- .../org/apache/hadoop/hbase/TableName.html | 169 +- .../hadoop/hbase/backup/BackupObserver.html | 2 +- .../impl/BackupCommands.BackupSetCommand.html |32 +- .../backup/impl/BackupCommands.Command.html |18 +- .../impl/BackupCommands.CreateCommand.html |37 +- .../impl/BackupCommands.DeleteCommand.html |10 +- .../impl/BackupCommands.DescribeCommand.html| 8 +- .../backup/impl/BackupCommands.HelpCommand.html | 8 +- .../impl/BackupCommands.HistoryCommand.html |18 +- .../impl/BackupCommands.MergeCommand.html |12 +- .../impl/BackupCommands.ProgressCommand.html| 8 +-
[45/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/apidocs/src-html/org/apache/hadoop/hbase/mapred/GroupingTableMap.html -- diff --git a/apidocs/src-html/org/apache/hadoop/hbase/mapred/GroupingTableMap.html b/apidocs/src-html/org/apache/hadoop/hbase/mapred/GroupingTableMap.html index ca89bf0..c42d8f3 100644 --- a/apidocs/src-html/org/apache/hadoop/hbase/mapred/GroupingTableMap.html +++ b/apidocs/src-html/org/apache/hadoop/hbase/mapred/GroupingTableMap.html @@ -32,137 +32,136 @@ 024import org.apache.yetus.audience.InterfaceAudience; 025import org.apache.hadoop.hbase.Cell; 026import org.apache.hadoop.hbase.CellUtil; -027import org.apache.hadoop.hbase.KeyValue; -028import org.apache.hadoop.hbase.client.Result; -029import org.apache.hadoop.hbase.io.ImmutableBytesWritable; -030import org.apache.hadoop.hbase.util.Bytes; -031import org.apache.hadoop.mapred.JobConf; -032import org.apache.hadoop.mapred.MapReduceBase; -033import org.apache.hadoop.mapred.OutputCollector; -034import org.apache.hadoop.mapred.Reporter; +027import org.apache.hadoop.hbase.client.Result; +028import org.apache.hadoop.hbase.io.ImmutableBytesWritable; +029import org.apache.hadoop.hbase.util.Bytes; +030import org.apache.hadoop.mapred.JobConf; +031import org.apache.hadoop.mapred.MapReduceBase; +032import org.apache.hadoop.mapred.OutputCollector; +033import org.apache.hadoop.mapred.Reporter; +034 035 -036 -037/** -038 * Extract grouping columns from input record -039 */ -040@InterfaceAudience.Public -041public class GroupingTableMap -042extends MapReduceBase -043implements TableMapImmutableBytesWritable,Result { -044 -045 /** -046 * JobConf parameter to specify the columns used to produce the key passed to -047 * collect from the map phase -048 */ -049 public static final String GROUP_COLUMNS = -050 "hbase.mapred.groupingtablemap.columns"; -051 -052 protected byte [][] columns; -053 -054 /** -055 * Use this before submitting a TableMap job. It will appropriately set up the -056 * JobConf. -057 * -058 * @param table table to be processed -059 * @param columns space separated list of columns to fetch -060 * @param groupColumns space separated list of columns used to form the key -061 * used in collect -062 * @param mapper map class -063 * @param job job configuration object -064 */ -065 @SuppressWarnings("unchecked") -066 public static void initJob(String table, String columns, String groupColumns, -067Class? extends TableMap mapper, JobConf job) { -068 -069 TableMapReduceUtil.initTableMapJob(table, columns, mapper, -070ImmutableBytesWritable.class, Result.class, job); -071job.set(GROUP_COLUMNS, groupColumns); -072 } -073 -074 @Override -075 public void configure(JobConf job) { -076super.configure(job); -077String[] cols = job.get(GROUP_COLUMNS, "").split(" "); -078columns = new byte[cols.length][]; -079for(int i = 0; i cols.length; i++) { -080 columns[i] = Bytes.toBytes(cols[i]); -081} -082 } -083 -084 /** -085 * Extract the grouping columns from value to construct a new key. -086 * -087 * Pass the new key and value to reduce. -088 * If any of the grouping columns are not found in the value, the record is skipped. -089 * @param key -090 * @param value -091 * @param output -092 * @param reporter -093 * @throws IOException -094 */ -095 public void map(ImmutableBytesWritable key, Result value, -096 OutputCollectorImmutableBytesWritable,Result output, -097 Reporter reporter) throws IOException { -098 -099byte[][] keyVals = extractKeyValues(value); -100if(keyVals != null) { -101 ImmutableBytesWritable tKey = createGroupKey(keyVals); -102 output.collect(tKey, value); -103} -104 } -105 -106 /** -107 * Extract columns values from the current record. This method returns -108 * null if any of the columns are not found. -109 * -110 * Override this method if you want to deal with nulls differently. -111 * -112 * @param r -113 * @return array of byte values -114 */ -115 protected byte[][] extractKeyValues(Result r) { -116byte[][] keyVals = null; -117ArrayListbyte[] foundList = new ArrayList(); -118int numCols = columns.length; -119if (numCols 0) { -120 for (Cell value: r.listCells()) { -121byte [] column = KeyValue.makeColumn(CellUtil.cloneFamily(value), -122 CellUtil.cloneQualifier(value)); -123for (int i = 0; i numCols; i++) { -124 if (Bytes.equals(column, columns[i])) { -125 foundList.add(CellUtil.cloneValue(value)); -126break; -127 } -128} -129 } -130 if(foundList.size() == numCols) { -131keyVals = foundList.toArray(new byte[numCols][]); -132 } -133} -134return keyVals; -135 } -136 -137 /** -138 * Create a key by concatenating
[19/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyByteBufferCell.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyByteBufferCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyByteBufferCell.html index 26125e3..eb6a00d 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyByteBufferCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyByteBufferCell.html @@ -28,3193 +28,3241 @@ 020 021import static org.apache.hadoop.hbase.HConstants.EMPTY_BYTE_ARRAY; 022import static org.apache.hadoop.hbase.Tag.TAG_LENGTH_SIZE; -023 -024import java.io.DataOutputStream; -025import java.io.IOException; -026import java.io.OutputStream; -027import java.math.BigDecimal; -028import java.nio.ByteBuffer; -029import java.util.ArrayList; -030import java.util.Arrays; -031import java.util.Iterator; -032import java.util.List; -033import java.util.Map.Entry; -034import java.util.NavigableMap; -035 -036import org.apache.hadoop.hbase.KeyValue.Type; -037import org.apache.yetus.audience.InterfaceAudience; -038import org.apache.yetus.audience.InterfaceAudience.Private; -039import org.apache.hadoop.hbase.io.HeapSize; -040import org.apache.hadoop.hbase.io.TagCompressionContext; -041import org.apache.hadoop.hbase.io.util.Dictionary; -042import org.apache.hadoop.hbase.io.util.StreamUtils; -043import org.apache.hadoop.hbase.util.ByteBufferUtils; -044import org.apache.hadoop.hbase.util.ByteRange; -045import org.apache.hadoop.hbase.util.Bytes; -046import org.apache.hadoop.hbase.util.ClassSize; -047 -048/** -049 * Utility methods helpful slinging {@link Cell} instances. -050 * Some methods below are for internal use only and are marked InterfaceAudience.Private at the -051 * method level. -052 */ -053@InterfaceAudience.Public -054public final class CellUtil { -055 -056 /** -057 * Private constructor to keep this class from being instantiated. -058 */ -059 private CellUtil(){} -060 -061 /*** ByteRange ***/ -062 -063 public static ByteRange fillRowRange(Cell cell, ByteRange range) { -064return range.set(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()); -065 } -066 -067 public static ByteRange fillFamilyRange(Cell cell, ByteRange range) { -068return range.set(cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength()); -069 } -070 -071 public static ByteRange fillQualifierRange(Cell cell, ByteRange range) { -072return range.set(cell.getQualifierArray(), cell.getQualifierOffset(), -073 cell.getQualifierLength()); -074 } -075 -076 public static ByteRange fillValueRange(Cell cell, ByteRange range) { -077return range.set(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength()); -078 } -079 -080 public static ByteRange fillTagRange(Cell cell, ByteRange range) { -081return range.set(cell.getTagsArray(), cell.getTagsOffset(), cell.getTagsLength()); -082 } -083 -084 /* get individual arrays for tests / -085 -086 public static byte[] cloneRow(Cell cell){ -087byte[] output = new byte[cell.getRowLength()]; -088copyRowTo(cell, output, 0); -089return output; -090 } -091 -092 public static byte[] cloneFamily(Cell cell){ -093byte[] output = new byte[cell.getFamilyLength()]; -094copyFamilyTo(cell, output, 0); -095return output; -096 } -097 -098 public static byte[] cloneQualifier(Cell cell){ -099byte[] output = new byte[cell.getQualifierLength()]; -100copyQualifierTo(cell, output, 0); -101return output; -102 } -103 -104 public static byte[] cloneValue(Cell cell){ -105byte[] output = new byte[cell.getValueLength()]; -106copyValueTo(cell, output, 0); -107return output; -108 } -109 -110 public static byte[] cloneTags(Cell cell) { -111byte[] output = new byte[cell.getTagsLength()]; -112copyTagTo(cell, output, 0); -113return output; -114 } -115 -116 /** -117 * Returns tag value in a new byte array. If server-side, use -118 * {@link Tag#getValueArray()} with appropriate {@link Tag#getValueOffset()} and -119 * {@link Tag#getValueLength()} instead to save on allocations. -120 * @param cell -121 * @return tag value in a new byte array. -122 */ -123 public static byte[] getTagArray(Cell cell){ -124byte[] output = new byte[cell.getTagsLength()]; -125copyTagTo(cell, output, 0); -126return output; -127 } -128 -129 -130 / copyTo **/ +023import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIMITER; +024import static org.apache.hadoop.hbase.KeyValue.getDelimiter; +025import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIM_ARRAY; +026 +027import java.io.DataOutputStream; +028import
[23/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/security/access/AccessController.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/security/access/AccessController.html b/devapidocs/org/apache/hadoop/hbase/security/access/AccessController.html index fc71a1a..e294712 100644 --- a/devapidocs/org/apache/hadoop/hbase/security/access/AccessController.html +++ b/devapidocs/org/apache/hadoop/hbase/security/access/AccessController.html @@ -114,7 +114,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.LimitedPrivate(value="Configuration") -public class AccessController +public class AccessController 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 MasterCoprocessor, RegionCoprocessor, RegionServerCoprocessor, org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.AccessControlService.Interface, MasterObserver, RegionObserver, RegionServerObserver, EndpointObserver, BulkLoadObserver Provides basic authorization checks for data access and administrative @@ -412,8 +412,8 @@ implements getRegionServerObserver() -http://docs.oracle.com/javase/8/docs/api/java/util/Optional.html?is-external=true; title="class or interface in java.util">Optionalcom.google.protobuf.Service -getService() +http://docs.oracle.com/javase/8/docs/api/java/lang/Iterable.html?is-external=true; title="class or interface in java.lang">Iterablecom.google.protobuf.Service +getServices() Coprocessor endpoints providing protobuf services should implement this interface. @@ -1504,7 +1504,7 @@ implements LOG -private static finalorg.apache.commons.logging.Log LOG +private static finalorg.apache.commons.logging.Log LOG @@ -1513,7 +1513,7 @@ implements AUDITLOG -private static finalorg.apache.commons.logging.Log AUDITLOG +private static finalorg.apache.commons.logging.Log AUDITLOG @@ -1522,7 +1522,7 @@ implements CHECK_COVERING_PERM -private static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String CHECK_COVERING_PERM +private static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String CHECK_COVERING_PERM See Also: Constant Field Values @@ -1535,7 +1535,7 @@ implements TAG_CHECK_PASSED -private static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String TAG_CHECK_PASSED +private static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String TAG_CHECK_PASSED See Also: Constant Field Values @@ -1548,7 +1548,7 @@ implements TRUE -private static finalbyte[] TRUE +private static finalbyte[] TRUE @@ -1557,7 +1557,7 @@ implements authManager -TableAuthManager authManager +TableAuthManager authManager @@ -1566,7 +1566,7 @@ implements aclRegion -boolean aclRegion +boolean aclRegion flags if we are running on a region of the _acl_ table @@ -1576,7 +1576,7 @@ implements regionEnv -privateRegionCoprocessorEnvironment regionEnv +privateRegionCoprocessorEnvironment regionEnv defined only for Endpoint implementation, so it can have way to access region services @@ -1587,7 +1587,7 @@ implements scannerOwners -privatehttp://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true; title="class or interface in java.util">MapInternalScanner,http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String scannerOwners +privatehttp://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true; title="class or interface in java.util">MapInternalScanner,http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String scannerOwners Mapping of scanner instances to the user who created them @@ -1597,7 +1597,7 @@ implements tableAcls -privatehttp://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true; title="class or interface in java.util">MapTableName,http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListUserPermission tableAcls +privatehttp://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true; title="class or interface in java.util">MapTableName,http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListUserPermission tableAcls @@ -1606,7 +1606,7 @@ implements userProvider -privateUserProvider userProvider +privateUserProvider userProvider Provider for mapping principal
[08/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowColByteBufferCell.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowColByteBufferCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowColByteBufferCell.html index 26125e3..eb6a00d 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowColByteBufferCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.LastOnRowColByteBufferCell.html @@ -28,3193 +28,3241 @@ 020 021import static org.apache.hadoop.hbase.HConstants.EMPTY_BYTE_ARRAY; 022import static org.apache.hadoop.hbase.Tag.TAG_LENGTH_SIZE; -023 -024import java.io.DataOutputStream; -025import java.io.IOException; -026import java.io.OutputStream; -027import java.math.BigDecimal; -028import java.nio.ByteBuffer; -029import java.util.ArrayList; -030import java.util.Arrays; -031import java.util.Iterator; -032import java.util.List; -033import java.util.Map.Entry; -034import java.util.NavigableMap; -035 -036import org.apache.hadoop.hbase.KeyValue.Type; -037import org.apache.yetus.audience.InterfaceAudience; -038import org.apache.yetus.audience.InterfaceAudience.Private; -039import org.apache.hadoop.hbase.io.HeapSize; -040import org.apache.hadoop.hbase.io.TagCompressionContext; -041import org.apache.hadoop.hbase.io.util.Dictionary; -042import org.apache.hadoop.hbase.io.util.StreamUtils; -043import org.apache.hadoop.hbase.util.ByteBufferUtils; -044import org.apache.hadoop.hbase.util.ByteRange; -045import org.apache.hadoop.hbase.util.Bytes; -046import org.apache.hadoop.hbase.util.ClassSize; -047 -048/** -049 * Utility methods helpful slinging {@link Cell} instances. -050 * Some methods below are for internal use only and are marked InterfaceAudience.Private at the -051 * method level. -052 */ -053@InterfaceAudience.Public -054public final class CellUtil { -055 -056 /** -057 * Private constructor to keep this class from being instantiated. -058 */ -059 private CellUtil(){} -060 -061 /*** ByteRange ***/ -062 -063 public static ByteRange fillRowRange(Cell cell, ByteRange range) { -064return range.set(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()); -065 } -066 -067 public static ByteRange fillFamilyRange(Cell cell, ByteRange range) { -068return range.set(cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength()); -069 } -070 -071 public static ByteRange fillQualifierRange(Cell cell, ByteRange range) { -072return range.set(cell.getQualifierArray(), cell.getQualifierOffset(), -073 cell.getQualifierLength()); -074 } -075 -076 public static ByteRange fillValueRange(Cell cell, ByteRange range) { -077return range.set(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength()); -078 } -079 -080 public static ByteRange fillTagRange(Cell cell, ByteRange range) { -081return range.set(cell.getTagsArray(), cell.getTagsOffset(), cell.getTagsLength()); -082 } -083 -084 /* get individual arrays for tests / -085 -086 public static byte[] cloneRow(Cell cell){ -087byte[] output = new byte[cell.getRowLength()]; -088copyRowTo(cell, output, 0); -089return output; -090 } -091 -092 public static byte[] cloneFamily(Cell cell){ -093byte[] output = new byte[cell.getFamilyLength()]; -094copyFamilyTo(cell, output, 0); -095return output; -096 } -097 -098 public static byte[] cloneQualifier(Cell cell){ -099byte[] output = new byte[cell.getQualifierLength()]; -100copyQualifierTo(cell, output, 0); -101return output; -102 } -103 -104 public static byte[] cloneValue(Cell cell){ -105byte[] output = new byte[cell.getValueLength()]; -106copyValueTo(cell, output, 0); -107return output; -108 } -109 -110 public static byte[] cloneTags(Cell cell) { -111byte[] output = new byte[cell.getTagsLength()]; -112copyTagTo(cell, output, 0); -113return output; -114 } -115 -116 /** -117 * Returns tag value in a new byte array. If server-side, use -118 * {@link Tag#getValueArray()} with appropriate {@link Tag#getValueOffset()} and -119 * {@link Tag#getValueLength()} instead to save on allocations. -120 * @param cell -121 * @return tag value in a new byte array. -122 */ -123 public static byte[] getTagArray(Cell cell){ -124byte[] output = new byte[cell.getTagsLength()]; -125copyTagTo(cell, output, 0); -126return output; -127 } -128 -129 -130 / copyTo **/ +023import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIMITER; +024import static org.apache.hadoop.hbase.KeyValue.getDelimiter; +025import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIM_ARRAY; +026 +027import
[13/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColTSByteBufferCell.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColTSByteBufferCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColTSByteBufferCell.html index 26125e3..eb6a00d 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColTSByteBufferCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColTSByteBufferCell.html @@ -28,3193 +28,3241 @@ 020 021import static org.apache.hadoop.hbase.HConstants.EMPTY_BYTE_ARRAY; 022import static org.apache.hadoop.hbase.Tag.TAG_LENGTH_SIZE; -023 -024import java.io.DataOutputStream; -025import java.io.IOException; -026import java.io.OutputStream; -027import java.math.BigDecimal; -028import java.nio.ByteBuffer; -029import java.util.ArrayList; -030import java.util.Arrays; -031import java.util.Iterator; -032import java.util.List; -033import java.util.Map.Entry; -034import java.util.NavigableMap; -035 -036import org.apache.hadoop.hbase.KeyValue.Type; -037import org.apache.yetus.audience.InterfaceAudience; -038import org.apache.yetus.audience.InterfaceAudience.Private; -039import org.apache.hadoop.hbase.io.HeapSize; -040import org.apache.hadoop.hbase.io.TagCompressionContext; -041import org.apache.hadoop.hbase.io.util.Dictionary; -042import org.apache.hadoop.hbase.io.util.StreamUtils; -043import org.apache.hadoop.hbase.util.ByteBufferUtils; -044import org.apache.hadoop.hbase.util.ByteRange; -045import org.apache.hadoop.hbase.util.Bytes; -046import org.apache.hadoop.hbase.util.ClassSize; -047 -048/** -049 * Utility methods helpful slinging {@link Cell} instances. -050 * Some methods below are for internal use only and are marked InterfaceAudience.Private at the -051 * method level. -052 */ -053@InterfaceAudience.Public -054public final class CellUtil { -055 -056 /** -057 * Private constructor to keep this class from being instantiated. -058 */ -059 private CellUtil(){} -060 -061 /*** ByteRange ***/ -062 -063 public static ByteRange fillRowRange(Cell cell, ByteRange range) { -064return range.set(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()); -065 } -066 -067 public static ByteRange fillFamilyRange(Cell cell, ByteRange range) { -068return range.set(cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength()); -069 } -070 -071 public static ByteRange fillQualifierRange(Cell cell, ByteRange range) { -072return range.set(cell.getQualifierArray(), cell.getQualifierOffset(), -073 cell.getQualifierLength()); -074 } -075 -076 public static ByteRange fillValueRange(Cell cell, ByteRange range) { -077return range.set(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength()); -078 } -079 -080 public static ByteRange fillTagRange(Cell cell, ByteRange range) { -081return range.set(cell.getTagsArray(), cell.getTagsOffset(), cell.getTagsLength()); -082 } -083 -084 /* get individual arrays for tests / -085 -086 public static byte[] cloneRow(Cell cell){ -087byte[] output = new byte[cell.getRowLength()]; -088copyRowTo(cell, output, 0); -089return output; -090 } -091 -092 public static byte[] cloneFamily(Cell cell){ -093byte[] output = new byte[cell.getFamilyLength()]; -094copyFamilyTo(cell, output, 0); -095return output; -096 } -097 -098 public static byte[] cloneQualifier(Cell cell){ -099byte[] output = new byte[cell.getQualifierLength()]; -100copyQualifierTo(cell, output, 0); -101return output; -102 } -103 -104 public static byte[] cloneValue(Cell cell){ -105byte[] output = new byte[cell.getValueLength()]; -106copyValueTo(cell, output, 0); -107return output; -108 } -109 -110 public static byte[] cloneTags(Cell cell) { -111byte[] output = new byte[cell.getTagsLength()]; -112copyTagTo(cell, output, 0); -113return output; -114 } -115 -116 /** -117 * Returns tag value in a new byte array. If server-side, use -118 * {@link Tag#getValueArray()} with appropriate {@link Tag#getValueOffset()} and -119 * {@link Tag#getValueLength()} instead to save on allocations. -120 * @param cell -121 * @return tag value in a new byte array. -122 */ -123 public static byte[] getTagArray(Cell cell){ -124byte[] output = new byte[cell.getTagsLength()]; -125copyTagTo(cell, output, 0); -126return output; -127 } -128 -129 -130 / copyTo **/ +023import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIMITER; +024import static org.apache.hadoop.hbase.KeyValue.getDelimiter; +025import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIM_ARRAY; +026
[12/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColTSCell.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColTSCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColTSCell.html index 26125e3..eb6a00d 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColTSCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColTSCell.html @@ -28,3193 +28,3241 @@ 020 021import static org.apache.hadoop.hbase.HConstants.EMPTY_BYTE_ARRAY; 022import static org.apache.hadoop.hbase.Tag.TAG_LENGTH_SIZE; -023 -024import java.io.DataOutputStream; -025import java.io.IOException; -026import java.io.OutputStream; -027import java.math.BigDecimal; -028import java.nio.ByteBuffer; -029import java.util.ArrayList; -030import java.util.Arrays; -031import java.util.Iterator; -032import java.util.List; -033import java.util.Map.Entry; -034import java.util.NavigableMap; -035 -036import org.apache.hadoop.hbase.KeyValue.Type; -037import org.apache.yetus.audience.InterfaceAudience; -038import org.apache.yetus.audience.InterfaceAudience.Private; -039import org.apache.hadoop.hbase.io.HeapSize; -040import org.apache.hadoop.hbase.io.TagCompressionContext; -041import org.apache.hadoop.hbase.io.util.Dictionary; -042import org.apache.hadoop.hbase.io.util.StreamUtils; -043import org.apache.hadoop.hbase.util.ByteBufferUtils; -044import org.apache.hadoop.hbase.util.ByteRange; -045import org.apache.hadoop.hbase.util.Bytes; -046import org.apache.hadoop.hbase.util.ClassSize; -047 -048/** -049 * Utility methods helpful slinging {@link Cell} instances. -050 * Some methods below are for internal use only and are marked InterfaceAudience.Private at the -051 * method level. -052 */ -053@InterfaceAudience.Public -054public final class CellUtil { -055 -056 /** -057 * Private constructor to keep this class from being instantiated. -058 */ -059 private CellUtil(){} -060 -061 /*** ByteRange ***/ -062 -063 public static ByteRange fillRowRange(Cell cell, ByteRange range) { -064return range.set(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()); -065 } -066 -067 public static ByteRange fillFamilyRange(Cell cell, ByteRange range) { -068return range.set(cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength()); -069 } -070 -071 public static ByteRange fillQualifierRange(Cell cell, ByteRange range) { -072return range.set(cell.getQualifierArray(), cell.getQualifierOffset(), -073 cell.getQualifierLength()); -074 } -075 -076 public static ByteRange fillValueRange(Cell cell, ByteRange range) { -077return range.set(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength()); -078 } -079 -080 public static ByteRange fillTagRange(Cell cell, ByteRange range) { -081return range.set(cell.getTagsArray(), cell.getTagsOffset(), cell.getTagsLength()); -082 } -083 -084 /* get individual arrays for tests / -085 -086 public static byte[] cloneRow(Cell cell){ -087byte[] output = new byte[cell.getRowLength()]; -088copyRowTo(cell, output, 0); -089return output; -090 } -091 -092 public static byte[] cloneFamily(Cell cell){ -093byte[] output = new byte[cell.getFamilyLength()]; -094copyFamilyTo(cell, output, 0); -095return output; -096 } -097 -098 public static byte[] cloneQualifier(Cell cell){ -099byte[] output = new byte[cell.getQualifierLength()]; -100copyQualifierTo(cell, output, 0); -101return output; -102 } -103 -104 public static byte[] cloneValue(Cell cell){ -105byte[] output = new byte[cell.getValueLength()]; -106copyValueTo(cell, output, 0); -107return output; -108 } -109 -110 public static byte[] cloneTags(Cell cell) { -111byte[] output = new byte[cell.getTagsLength()]; -112copyTagTo(cell, output, 0); -113return output; -114 } -115 -116 /** -117 * Returns tag value in a new byte array. If server-side, use -118 * {@link Tag#getValueArray()} with appropriate {@link Tag#getValueOffset()} and -119 * {@link Tag#getValueLength()} instead to save on allocations. -120 * @param cell -121 * @return tag value in a new byte array. -122 */ -123 public static byte[] getTagArray(Cell cell){ -124byte[] output = new byte[cell.getTagsLength()]; -125copyTagTo(cell, output, 0); -126return output; -127 } -128 -129 -130 / copyTo **/ +023import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIMITER; +024import static org.apache.hadoop.hbase.KeyValue.getDelimiter; +025import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIM_ARRAY; +026 +027import java.io.DataOutputStream; +028import
[27/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/master/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/package-tree.html b/devapidocs/org/apache/hadoop/hbase/master/package-tree.html index 0a18321..6f42d6a 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/master/package-tree.html @@ -320,11 +320,11 @@ java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable) -org.apache.hadoop.hbase.master.RegionState.State -org.apache.hadoop.hbase.master.SplitLogManager.TerminationStatus -org.apache.hadoop.hbase.master.MetricsMasterSourceFactoryImpl.FactoryStorage org.apache.hadoop.hbase.master.MasterRpcServices.BalanceSwitchMode +org.apache.hadoop.hbase.master.MetricsMasterSourceFactoryImpl.FactoryStorage org.apache.hadoop.hbase.master.SplitLogManager.ResubmitDirective +org.apache.hadoop.hbase.master.RegionState.State +org.apache.hadoop.hbase.master.SplitLogManager.TerminationStatus http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/package-frame.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/package-frame.html b/devapidocs/org/apache/hadoop/hbase/package-frame.html index 4b6de90..498a162 100644 --- a/devapidocs/org/apache/hadoop/hbase/package-frame.html +++ b/devapidocs/org/apache/hadoop/hbase/package-frame.html @@ -103,8 +103,6 @@ KeyValue.KeyOnlyKeyValue KeyValue.KVComparator KeyValue.MetaComparator -KeyValue.RawBytesComparator -KeyValue.RowOnlyComparator KeyValueBuilder KeyValueTestUtil KeyValueUtil http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/package-summary.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/package-summary.html b/devapidocs/org/apache/hadoop/hbase/package-summary.html index cd5c793..5af5e45 100644 --- a/devapidocs/org/apache/hadoop/hbase/package-summary.html +++ b/devapidocs/org/apache/hadoop/hbase/package-summary.html @@ -128,7 +128,8 @@ Coprocessor -Coprocessor interface. +Base interface for the 4 coprocessors - MasterCoprocessor, RegionCoprocessor, + RegionServerCoprocessor, and WALCoprocessor. @@ -584,19 +585,7 @@ KeyValue.MetaComparator Deprecated -: CellComparator.META_COMPARATOR to be used - - - -KeyValue.RawBytesComparator -Deprecated -Not to be used for any comparsions - - - -KeyValue.RowOnlyComparator - -Comparator that compares row component only of a KeyValue. +: CellComparator.META_COMPARATOR to be used. http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/package-tree.html b/devapidocs/org/apache/hadoop/hbase/package-tree.html index 7066dc3..52e9f1b 100644 --- a/devapidocs/org/apache/hadoop/hbase/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/package-tree.html @@ -227,10 +227,8 @@ org.apache.hadoop.hbase.KeyValue.KVComparator (implements org.apache.hadoop.hbase.KeyValue.SamePrefixComparatorT, org.apache.hadoop.io.RawComparatorT) org.apache.hadoop.hbase.KeyValue.MetaComparator -org.apache.hadoop.hbase.KeyValue.RawBytesComparator -org.apache.hadoop.hbase.KeyValue.RowOnlyComparator (implements java.util.http://docs.oracle.com/javase/8/docs/api/java/util/Comparator.html?is-external=true; title="class or interface in java.util">ComparatorT) org.apache.hadoop.hbase.KeyValueTestUtil org.apache.hadoop.hbase.KeyValueUtil org.apache.hadoop.hbase.LocalHBaseCluster @@ -429,17 +427,17 @@ java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable) +org.apache.hadoop.hbase.HealthChecker.HealthCheckerExitStatus org.apache.hadoop.hbase.CompareOperator org.apache.hadoop.hbase.CompatibilitySingletonFactory.SingletonStorage -org.apache.hadoop.hbase.MetaTableAccessor.QueryType -org.apache.hadoop.hbase.Coprocessor.State
[25/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.RegionServerEnvironment.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.RegionServerEnvironment.html b/devapidocs/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.RegionServerEnvironment.html index c91be32..f262afd 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.RegionServerEnvironment.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.RegionServerEnvironment.html @@ -122,7 +122,7 @@ var activeTableTab = "activeTableTab"; -private static class RegionServerCoprocessorHost.RegionServerEnvironment +private static class RegionServerCoprocessorHost.RegionServerEnvironment extends BaseEnvironmentRegionServerCoprocessor implements RegionServerCoprocessorEnvironment Coprocessor environment extension providing access to region server @@ -256,7 +256,7 @@ implements regionServerServices -private finalRegionServerServices regionServerServices +private finalRegionServerServices regionServerServices @@ -265,7 +265,7 @@ implements metricRegistry -private finalMetricRegistry metricRegistry +private finalMetricRegistry metricRegistry @@ -282,7 +282,7 @@ implements RegionServerEnvironment -publicRegionServerEnvironment(RegionServerCoprocessorimpl, +publicRegionServerEnvironment(RegionServerCoprocessorimpl, intpriority, intseq, org.apache.hadoop.conf.Configurationconf, @@ -303,7 +303,7 @@ implements getCoprocessorRegionServerServices -publicCoprocessorRegionServerServicesgetCoprocessorRegionServerServices() +publicCoprocessorRegionServerServicesgetCoprocessorRegionServerServices() Description copied from interface:RegionServerCoprocessorEnvironment Gets the region server services. @@ -320,7 +320,7 @@ implements getMetricRegistryForRegionServer -publicMetricRegistrygetMetricRegistryForRegionServer() +publicMetricRegistrygetMetricRegistryForRegionServer() Description copied from interface:RegionServerCoprocessorEnvironment Returns a MetricRegistry that can be used to track metrics at the region server level. @@ -340,7 +340,7 @@ implements shutdown -publicvoidshutdown() +publicvoidshutdown() Description copied from class:BaseEnvironment Clean up the environment http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.RegionServerObserverOperation.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.RegionServerObserverOperation.html b/devapidocs/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.RegionServerObserverOperation.html index 67ad118..9a98c9d 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.RegionServerObserverOperation.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.RegionServerObserverOperation.html @@ -122,7 +122,7 @@ -abstract class RegionServerCoprocessorHost.RegionServerObserverOperation +abstract class RegionServerCoprocessorHost.RegionServerObserverOperation extends CoprocessorHost.ObserverOperationWithoutResultRegionServerObserver @@ -204,7 +204,7 @@ extends RegionServerObserverOperation -publicRegionServerObserverOperation() +publicRegionServerObserverOperation() @@ -213,7 +213,7 @@ extends RegionServerObserverOperation -publicRegionServerObserverOperation(Useruser) +publicRegionServerObserverOperation(Useruser) http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.html b/devapidocs/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.html index 53f6a87..275420c 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.html @@ -116,7 +116,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.LimitedPrivate(value="Coprocesssor") @InterfaceStability.Evolving -public class RegionServerCoprocessorHost +public class RegionServerCoprocessorHost extends CoprocessorHostRegionServerCoprocessor,RegionServerCoprocessorEnvironment @@ -304,7 +304,7 @@ extends LOG -private static finalorg.apache.commons.logging.Log LOG +private static finalorg.apache.commons.logging.Log LOG @@ -313,7 +313,7
[50/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/apidocs/index-all.html -- diff --git a/apidocs/index-all.html b/apidocs/index-all.html index 721caa3..dedcca3 100644 --- a/apidocs/index-all.html +++ b/apidocs/index-all.html @@ -7400,13 +7400,6 @@ misc -getRowComparator() - Method in class org.apache.hadoop.hbase.TableName - -Deprecated. -The comparator is an internal property of the table. Should - not have been exposed here - - getRowLength() - Method in interface org.apache.hadoop.hbase.Cell getRowOffset() - Method in interface org.apache.hadoop.hbase.Cell @@ -10859,6 +10852,10 @@ Compact all regions on the region server. +makeColumn(byte[], byte[]) - Static method in class org.apache.hadoop.hbase.CellUtil + +Makes a column in family:qualifier form from separate byte arrays. + map(ImmutableBytesWritable, Result, OutputCollectorImmutableBytesWritable, Result, Reporter) - Method in class org.apache.hadoop.hbase.mapred.GroupingTableMap Extract the grouping columns from value to construct a new key. @@ -12195,6 +12192,10 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. Constructor +parseColumn(byte[]) - Static method in class org.apache.hadoop.hbase.CellUtil + +Splits a column in family:qualifier form into separate byte arrays. + parseComparator(byte[]) - Static method in class org.apache.hadoop.hbase.filter.ParseFilter Splits a column in comparatorType:comparatorValue form into separate byte arrays
[20/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/thrift/ThriftServerRunner.IOErrorWithCause.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/thrift/ThriftServerRunner.IOErrorWithCause.html b/devapidocs/org/apache/hadoop/hbase/thrift/ThriftServerRunner.IOErrorWithCause.html index a9f254b..ecda737 100644 --- a/devapidocs/org/apache/hadoop/hbase/thrift/ThriftServerRunner.IOErrorWithCause.html +++ b/devapidocs/org/apache/hadoop/hbase/thrift/ThriftServerRunner.IOErrorWithCause.html @@ -137,7 +137,7 @@ var activeTableTab = "activeTableTab"; -public static class ThriftServerRunner.IOErrorWithCause +public static class ThriftServerRunner.IOErrorWithCause extends org.apache.hadoop.hbase.thrift.generated.IOError See Also: @@ -273,7 +273,7 @@ extends org.apache.hadoop.hbase.thrift.generated.IOError cause -privatehttp://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true; title="class or interface in java.lang">Throwable cause +privatehttp://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true; title="class or interface in java.lang">Throwable cause @@ -290,7 +290,7 @@ extends org.apache.hadoop.hbase.thrift.generated.IOError IOErrorWithCause -publicIOErrorWithCause(http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true; title="class or interface in java.lang">Throwablecause) +publicIOErrorWithCause(http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true; title="class or interface in java.lang">Throwablecause) @@ -307,7 +307,7 @@ extends org.apache.hadoop.hbase.thrift.generated.IOError getCause -publichttp://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true; title="class or interface in java.lang">ThrowablegetCause() +publichttp://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true; title="class or interface in java.lang">ThrowablegetCause() Overrides: http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true#getCause--; title="class or interface in java.lang">getCausein classhttp://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true; title="class or interface in java.lang">Throwable @@ -320,7 +320,7 @@ extends org.apache.hadoop.hbase.thrift.generated.IOError equals -publicbooleanequals(http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Objectother) +publicbooleanequals(http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Objectother) Overrides: equalsin classorg.apache.hadoop.hbase.thrift.generated.IOError @@ -333,7 +333,7 @@ extends org.apache.hadoop.hbase.thrift.generated.IOError hashCode -publicinthashCode() +publicinthashCode() Overrides: hashCodein classorg.apache.hadoop.hbase.thrift.generated.IOError http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/thrift/ThriftServerRunner.ImplType.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/thrift/ThriftServerRunner.ImplType.html b/devapidocs/org/apache/hadoop/hbase/thrift/ThriftServerRunner.ImplType.html index 0b4233c..0cf76c1 100644 --- a/devapidocs/org/apache/hadoop/hbase/thrift/ThriftServerRunner.ImplType.html +++ b/devapidocs/org/apache/hadoop/hbase/thrift/ThriftServerRunner.ImplType.html @@ -122,7 +122,7 @@ var activeTableTab = "activeTableTab"; -static enum ThriftServerRunner.ImplType +static enum ThriftServerRunner.ImplType extends http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumThriftServerRunner.ImplType An enum of server implementation selections @@ -281,7 +281,7 @@ the order they are declared. HS_HA -public static finalThriftServerRunner.ImplType HS_HA +public static finalThriftServerRunner.ImplType HS_HA @@ -290,7 +290,7 @@ the order they are declared. NONBLOCKING -public static finalThriftServerRunner.ImplType NONBLOCKING +public static finalThriftServerRunner.ImplType NONBLOCKING @@ -299,7 +299,7 @@ the order they are declared. THREAD_POOL -public static finalThriftServerRunner.ImplType THREAD_POOL +public static finalThriftServerRunner.ImplType THREAD_POOL @@ -308,7 +308,7 @@ the order they are declared. THREADED_SELECTOR -public static finalThriftServerRunner.ImplType THREADED_SELECTOR +public static finalThriftServerRunner.ImplType THREADED_SELECTOR @@ -325,7 +325,7 @@ the order they are declared. DEFAULT -public static finalThriftServerRunner.ImplType DEFAULT +public static finalThriftServerRunner.ImplType DEFAULT @@ -334,7 +334,7 @@ the order
[11/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowDeleteFamilyCell.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowDeleteFamilyCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowDeleteFamilyCell.html index 26125e3..eb6a00d 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowDeleteFamilyCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowDeleteFamilyCell.html @@ -28,3193 +28,3241 @@ 020 021import static org.apache.hadoop.hbase.HConstants.EMPTY_BYTE_ARRAY; 022import static org.apache.hadoop.hbase.Tag.TAG_LENGTH_SIZE; -023 -024import java.io.DataOutputStream; -025import java.io.IOException; -026import java.io.OutputStream; -027import java.math.BigDecimal; -028import java.nio.ByteBuffer; -029import java.util.ArrayList; -030import java.util.Arrays; -031import java.util.Iterator; -032import java.util.List; -033import java.util.Map.Entry; -034import java.util.NavigableMap; -035 -036import org.apache.hadoop.hbase.KeyValue.Type; -037import org.apache.yetus.audience.InterfaceAudience; -038import org.apache.yetus.audience.InterfaceAudience.Private; -039import org.apache.hadoop.hbase.io.HeapSize; -040import org.apache.hadoop.hbase.io.TagCompressionContext; -041import org.apache.hadoop.hbase.io.util.Dictionary; -042import org.apache.hadoop.hbase.io.util.StreamUtils; -043import org.apache.hadoop.hbase.util.ByteBufferUtils; -044import org.apache.hadoop.hbase.util.ByteRange; -045import org.apache.hadoop.hbase.util.Bytes; -046import org.apache.hadoop.hbase.util.ClassSize; -047 -048/** -049 * Utility methods helpful slinging {@link Cell} instances. -050 * Some methods below are for internal use only and are marked InterfaceAudience.Private at the -051 * method level. -052 */ -053@InterfaceAudience.Public -054public final class CellUtil { -055 -056 /** -057 * Private constructor to keep this class from being instantiated. -058 */ -059 private CellUtil(){} -060 -061 /*** ByteRange ***/ -062 -063 public static ByteRange fillRowRange(Cell cell, ByteRange range) { -064return range.set(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()); -065 } -066 -067 public static ByteRange fillFamilyRange(Cell cell, ByteRange range) { -068return range.set(cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength()); -069 } -070 -071 public static ByteRange fillQualifierRange(Cell cell, ByteRange range) { -072return range.set(cell.getQualifierArray(), cell.getQualifierOffset(), -073 cell.getQualifierLength()); -074 } -075 -076 public static ByteRange fillValueRange(Cell cell, ByteRange range) { -077return range.set(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength()); -078 } -079 -080 public static ByteRange fillTagRange(Cell cell, ByteRange range) { -081return range.set(cell.getTagsArray(), cell.getTagsOffset(), cell.getTagsLength()); -082 } -083 -084 /* get individual arrays for tests / -085 -086 public static byte[] cloneRow(Cell cell){ -087byte[] output = new byte[cell.getRowLength()]; -088copyRowTo(cell, output, 0); -089return output; -090 } -091 -092 public static byte[] cloneFamily(Cell cell){ -093byte[] output = new byte[cell.getFamilyLength()]; -094copyFamilyTo(cell, output, 0); -095return output; -096 } -097 -098 public static byte[] cloneQualifier(Cell cell){ -099byte[] output = new byte[cell.getQualifierLength()]; -100copyQualifierTo(cell, output, 0); -101return output; -102 } -103 -104 public static byte[] cloneValue(Cell cell){ -105byte[] output = new byte[cell.getValueLength()]; -106copyValueTo(cell, output, 0); -107return output; -108 } -109 -110 public static byte[] cloneTags(Cell cell) { -111byte[] output = new byte[cell.getTagsLength()]; -112copyTagTo(cell, output, 0); -113return output; -114 } -115 -116 /** -117 * Returns tag value in a new byte array. If server-side, use -118 * {@link Tag#getValueArray()} with appropriate {@link Tag#getValueOffset()} and -119 * {@link Tag#getValueLength()} instead to save on allocations. -120 * @param cell -121 * @return tag value in a new byte array. -122 */ -123 public static byte[] getTagArray(Cell cell){ -124byte[] output = new byte[cell.getTagsLength()]; -125copyTagTo(cell, output, 0); -126return output; -127 } -128 -129 -130 / copyTo **/ +023import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIMITER; +024import static org.apache.hadoop.hbase.KeyValue.getDelimiter; +025import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIM_ARRAY; +026 +027import
[37/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/Coprocessor.State.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/Coprocessor.State.html b/devapidocs/org/apache/hadoop/hbase/Coprocessor.State.html index 123c69b..bfbdbe1 100644 --- a/devapidocs/org/apache/hadoop/hbase/Coprocessor.State.html +++ b/devapidocs/org/apache/hadoop/hbase/Coprocessor.State.html @@ -122,7 +122,7 @@ var activeTableTab = "activeTableTab"; -public static enum Coprocessor.State +public static enum Coprocessor.State extends http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumCoprocessor.State Lifecycle state of a given coprocessor instance. @@ -223,7 +223,7 @@ the order they are declared. UNINSTALLED -public static finalCoprocessor.State UNINSTALLED +public static finalCoprocessor.State UNINSTALLED @@ -232,7 +232,7 @@ the order they are declared. INSTALLED -public static finalCoprocessor.State INSTALLED +public static finalCoprocessor.State INSTALLED @@ -241,7 +241,7 @@ the order they are declared. STARTING -public static finalCoprocessor.State STARTING +public static finalCoprocessor.State STARTING @@ -250,7 +250,7 @@ the order they are declared. ACTIVE -public static finalCoprocessor.State ACTIVE +public static finalCoprocessor.State ACTIVE @@ -259,7 +259,7 @@ the order they are declared. STOPPING -public static finalCoprocessor.State STOPPING +public static finalCoprocessor.State STOPPING @@ -268,7 +268,7 @@ the order they are declared. STOPPED -public static finalCoprocessor.State STOPPED +public static finalCoprocessor.State STOPPED @@ -285,7 +285,7 @@ the order they are declared. values -public staticCoprocessor.State[]values() +public staticCoprocessor.State[]values() Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows: @@ -305,7 +305,7 @@ for (Coprocessor.State c : Coprocessor.State.values()) valueOf -public staticCoprocessor.StatevalueOf(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) +public staticCoprocessor.StatevalueOf(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/Coprocessor.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/Coprocessor.html b/devapidocs/org/apache/hadoop/hbase/Coprocessor.html index bdb9056..0d19bf2 100644 --- a/devapidocs/org/apache/hadoop/hbase/Coprocessor.html +++ b/devapidocs/org/apache/hadoop/hbase/Coprocessor.html @@ -111,8 +111,36 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.LimitedPrivate(value="Coprocesssor") @InterfaceStability.Evolving -public interface Coprocessor -Coprocessor interface. +public interface Coprocessor +Base interface for the 4 coprocessors - MasterCoprocessor, RegionCoprocessor, + RegionServerCoprocessor, and WALCoprocessor. + Do NOT implement this interface directly. Unless an implementation implements one (or more) of + the above mentioned 4 coprocessors, it'll fail to be loaded by any coprocessor host. + + Example: + Building a coprocessor to observe Master operations. + + class MyMasterCoprocessor implements MasterCoprocessor { + Override + public OptionalMasterObserver> getMasterObserver() { + return new MyMasterObserver(); + } + } + + class MyMasterObserver implements MasterObserver { + + } + + + Building a Service which can be loaded by both Master and RegionServer + + class MyCoprocessorService implements MasterCoprocessor, RegionServerCoprocessor { + Override + public OptionalService> getServices() { + return new ...; + } + } + @@ -196,8 +224,8 @@ public interface Method and Description -default http://docs.oracle.com/javase/8/docs/api/java/util/Optional.html?is-external=true; title="class or interface in java.util">Optionalcom.google.protobuf.Service -getService() +default http://docs.oracle.com/javase/8/docs/api/java/lang/Iterable.html?is-external=true; title="class or interface in java.lang">Iterablecom.google.protobuf.Service +getServices() Coprocessor endpoints providing protobuf services should implement this interface. @@ -236,7 +264,7 @@ public interface VERSION -static finalint VERSION +static finalint VERSION See Also: Constant Field Values @@ -249,7
[48/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/apidocs/org/apache/hadoop/hbase/TableName.html -- diff --git a/apidocs/org/apache/hadoop/hbase/TableName.html b/apidocs/org/apache/hadoop/hbase/TableName.html index 7b43dc2..9ead350 100644 --- a/apidocs/org/apache/hadoop/hbase/TableName.html +++ b/apidocs/org/apache/hadoop/hbase/TableName.html @@ -114,7 +114,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Public -public final class TableName +public final class TableName 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 http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableTableName Immutable POJO class for representing a table name. @@ -383,7 +383,7 @@ implements http://docs.oracle.com/javase/8/docs/api/java/lang/Comparabl NAMESPACE_DELIM -public static finalchar NAMESPACE_DELIM +public static finalchar NAMESPACE_DELIM Namespace delimiter See Also: @@ -397,7 +397,7 @@ implements http://docs.oracle.com/javase/8/docs/api/java/lang/Comparabl VALID_NAMESPACE_REGEX -public static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String VALID_NAMESPACE_REGEX +public static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String VALID_NAMESPACE_REGEX See Also: Constant Field Values @@ -410,7 +410,7 @@ implements http://docs.oracle.com/javase/8/docs/api/java/lang/Comparabl VALID_TABLE_QUALIFIER_REGEX -public static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String VALID_TABLE_QUALIFIER_REGEX +public static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String VALID_TABLE_QUALIFIER_REGEX See Also: Constant Field Values @@ -423,7 +423,7 @@ implements http://docs.oracle.com/javase/8/docs/api/java/lang/Comparabl VALID_USER_TABLE_REGEX -public static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String VALID_USER_TABLE_REGEX +public static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String VALID_USER_TABLE_REGEX See Also: Constant Field Values @@ -436,7 +436,7 @@ implements http://docs.oracle.com/javase/8/docs/api/java/lang/Comparabl META_TABLE_NAME -public static finalTableName META_TABLE_NAME +public static finalTableName META_TABLE_NAME The hbase:meta table's name. @@ -446,7 +446,7 @@ implements http://docs.oracle.com/javase/8/docs/api/java/lang/Comparabl NAMESPACE_TABLE_NAME -public static finalTableName NAMESPACE_TABLE_NAME +public static finalTableName NAMESPACE_TABLE_NAME The Namespace table's name. @@ -456,7 +456,7 @@ implements http://docs.oracle.com/javase/8/docs/api/java/lang/Comparabl OLD_META_STR -public static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String OLD_META_STR +public static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String OLD_META_STR See Also: Constant Field Values @@ -469,7 +469,7 @@ implements http://docs.oracle.com/javase/8/docs/api/java/lang/Comparabl OLD_ROOT_STR -public static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String OLD_ROOT_STR +public static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String OLD_ROOT_STR See Also: Constant Field Values @@ -482,7 +482,7 @@ implements http://docs.oracle.com/javase/8/docs/api/java/lang/Comparabl DISALLOWED_TABLE_NAME -public static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String DISALLOWED_TABLE_NAME +public static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String DISALLOWED_TABLE_NAME One globally disallowed name See Also: @@ -496,7 +496,7 @@ implements http://docs.oracle.com/javase/8/docs/api/java/lang/Comparabl OLD_ROOT_TABLE_NAME -public static finalTableName OLD_ROOT_TABLE_NAME +public static finalTableName OLD_ROOT_TABLE_NAME TableName for old -ROOT- table. It is used to read/process old WALs which have ROOT edits. @@ -507,7 +507,7 @@ implements
[44/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/checkstyle-aggregate.html -- diff --git a/checkstyle-aggregate.html b/checkstyle-aggregate.html index a9c1c27..7837e79 100644 --- a/checkstyle-aggregate.html +++ b/checkstyle-aggregate.html @@ -7,7 +7,7 @@ - + Apache HBase Checkstyle Results @@ -289,7 +289,7 @@ 2051 0 0 -13704 +13690 Files @@ -367,7 +367,7 @@ org/apache/hadoop/hbase/CellUtil.java 0 0 -99 +103 org/apache/hadoop/hbase/ChoreService.java 0 @@ -492,7 +492,7 @@ org/apache/hadoop/hbase/KeyValue.java 0 0 -136 +120 org/apache/hadoop/hbase/KeyValueTestUtil.java 0 @@ -612,7 +612,7 @@ org/apache/hadoop/hbase/TableName.java 0 0 -21 +18 org/apache/hadoop/hbase/TableNotDisabledException.java 0 @@ -767,7 +767,7 @@ org/apache/hadoop/hbase/backup/impl/BackupCommands.java 0 0 -56 +55 org/apache/hadoop/hbase/backup/impl/BackupManager.java 0 @@ -1327,7 +1327,7 @@ org/apache/hadoop/hbase/client/RegionInfoBuilder.java 0 0 -6 +7 org/apache/hadoop/hbase/client/RegionInfoDisplay.java 0 @@ -3617,7 +3617,7 @@ org/apache/hadoop/hbase/master/MasterCoprocessorHost.java 0 0 -13 +14 org/apache/hadoop/hbase/master/MasterDumpServlet.java 0 @@ -5347,7 +5347,7 @@ org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.java 0 0 -4 +5 org/apache/hadoop/hbase/regionserver/RegionServerServices.java 0 @@ -6702,7 +6702,7 @@ org/apache/hadoop/hbase/security/access/AccessController.java 0 0 -39 +37 org/apache/hadoop/hbase/security/access/AuthResult.java 0 @@ -7087,7 +7087,7 @@ org/apache/hadoop/hbase/thrift/ThriftServerRunner.java 0 0 -22 +23 org/apache/hadoop/hbase/thrift/ThriftUtilities.java 0 @@ -8174,7 +8174,7 @@ annotation http://checkstyle.sourceforge.net/config_annotation.html#MissingDeprecated;>MissingDeprecated -82 +79 Error blocks @@ -8251,7 +8251,7 @@ ordered: true sortStaticImportsAlphabetically: true option: top -1847 +1850 Error @@ -8274,19 +8274,19 @@ caseIndent: 2 basicOffset: 2 lineWrappingIndentation: 2 -3764 +3763 Error javadoc http://checkstyle.sourceforge.net/config_javadoc.html#JavadocTagContinuationIndentation;>JavadocTagContinuationIndentation offset: 2 -765 +757 Error http://checkstyle.sourceforge.net/config_javadoc.html#NonEmptyAtclauseDescription;>NonEmptyAtclauseDescription -3281 +3273 Error misc @@ -8304,7 +8304,7 @@ max: 100 ignorePattern: ^package.*|^import.*|a href|href|http://|https://|ftp://|org.apache.thrift.|com.google.protobuf.|hbase.protobuf.generated -1105 +1108 Error @@ -9088,596 +9088,620 @@ Error imports ImportOrder +Wrong order for 'org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIMITER' import. +23 + +Error +imports +ImportOrder +Wrong order for 'org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIM_ARRAY' import. +25 + +Error +imports +ImportOrder Wrong order for 'org.apache.hadoop.hbase.io.HeapSize' import. -39 +42 Error javadoc NonEmptyAtclauseDescription At-clause should have a non-empty description. -120 +123 Error javadoc NonEmptyAtclauseDescription At-clause should have a non-empty description. -250 +136 Error javadoc NonEmptyAtclauseDescription At-clause should have a non-empty description. -251 +137 Error javadoc NonEmptyAtclauseDescription At-clause should have a non-empty description. -252 +298 Error javadoc NonEmptyAtclauseDescription At-clause should have a non-empty description. -307 +299 Error javadoc NonEmptyAtclauseDescription At-clause should have a non-empty description. -411 +300 Error javadoc NonEmptyAtclauseDescription At-clause should have a non-empty description. -423 +355 Error javadoc NonEmptyAtclauseDescription At-clause should have a non-empty description. -424 +459 Error javadoc NonEmptyAtclauseDescription At-clause should have a non-empty description. -441 +471 Error javadoc NonEmptyAtclauseDescription At-clause should have a non-empty description. -442 +472 Error javadoc NonEmptyAtclauseDescription At-clause should have a non-empty description. -443 +489 + +Error +javadoc +NonEmptyAtclauseDescription +At-clause should have a non-empty description. +490 + +Error +javadoc +NonEmptyAtclauseDescription +At-clause should have a non-empty description. +491 Error sizes LineLength Line is longer than 100 characters (found 101). -480 +528 Error sizes LineLength Line is longer than 100 characters (found 101). -481 +529 Error blocks NeedBraces 'if' construct must use '{}'s. -947 +995 Error javadoc NonEmptyAtclauseDescription At-clause should have a non-empty description. -1061 +1109 Error blocks NeedBraces 'if' construct must use '{}'s. -1079 +1127 Error blocks NeedBraces 'if' construct must use '{}'s. -1082 +1130 Error javadoc NonEmptyAtclauseDescription At-clause should have a non-empty description. -1090
[30/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/class-use/Coprocessor.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/Coprocessor.html b/devapidocs/org/apache/hadoop/hbase/class-use/Coprocessor.html index 31ec3cc..a15f123 100644 --- a/devapidocs/org/apache/hadoop/hbase/class-use/Coprocessor.html +++ b/devapidocs/org/apache/hadoop/hbase/class-use/Coprocessor.html @@ -266,7 +266,7 @@ interface WALCoprocessor -WALCoprocessor don't support loading services using getService(). +WALCoprocessor don't support loading services using getServices(). http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/class-use/KeyValue.KVComparator.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/KeyValue.KVComparator.html b/devapidocs/org/apache/hadoop/hbase/class-use/KeyValue.KVComparator.html index 1cec6e2..eb3c10d 100644 --- a/devapidocs/org/apache/hadoop/hbase/class-use/KeyValue.KVComparator.html +++ b/devapidocs/org/apache/hadoop/hbase/class-use/KeyValue.KVComparator.html @@ -86,12 +86,6 @@ org.apache.hadoop.hbase - -org.apache.hadoop.hbase.client - -Provides HBase Client - - @@ -112,15 +106,7 @@ static class KeyValue.MetaComparator Deprecated. -: CellComparator.META_COMPARATOR to be used - - - - -static class -KeyValue.RawBytesComparator -Deprecated. -Not to be used for any comparsions +: CellComparator.META_COMPARATOR to be used. Deprecated for hbase 2.0, remove for hbase 3.0. @@ -134,31 +120,21 @@ -(package private) KeyValue.KVComparator -KeyValue.RowOnlyComparator.comparator - - static KeyValue.KVComparator KeyValue.COMPARATOR Deprecated. -Use CellComparator.COMPARATOR instead +Use CellComparator.COMPARATOR instead. Deprecated for hbase 2.0, remove for hbase 3.0. - + static KeyValue.KVComparator KeyValue.META_COMPARATOR Deprecated. -Use CellComparator.META_COMPARATOR instead +Use CellComparator.META_COMPARATOR instead. Deprecated for hbase 2.0, remove for hbase 3.0. - -static KeyValue.KVComparator -KeyValue.RAW_COMPARATOR -Deprecated. - - @@ -176,48 +152,6 @@ - -KeyValue.KVComparator -TableName.getRowComparator() -Deprecated. -The comparator is an internal property of the table. Should - not have been exposed here - - - - - - -Constructors in org.apache.hadoop.hbase with parameters of type KeyValue.KVComparator - -Constructor and Description - - - -RowOnlyComparator(KeyValue.KVComparatorc) - - - - - - - -Uses of KeyValue.KVComparator in org.apache.hadoop.hbase.client - -Methods in org.apache.hadoop.hbase.client that return KeyValue.KVComparator - -Modifier and Type -Method and Description - - - -KeyValue.KVComparator -RegionInfoBuilder.MutableRegionInfo.getComparator() -Deprecated. -Use Region#getCellComparator(). deprecated for hbase 2.0, remove for hbase 3.0 - - - http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/class-use/KeyValue.RawBytesComparator.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/KeyValue.RawBytesComparator.html b/devapidocs/org/apache/hadoop/hbase/class-use/KeyValue.RawBytesComparator.html deleted file mode 100644 index 8fd8987..000 --- a/devapidocs/org/apache/hadoop/hbase/class-use/KeyValue.RawBytesComparator.html +++ /dev/null @@ -1,125 +0,0 @@ -http://www.w3.org/TR/html4/loose.dtd;> - - - - - -Uses of Class org.apache.hadoop.hbase.KeyValue.RawBytesComparator (Apache HBase 3.0.0-SNAPSHOT API) - - - - - - - -JavaScript is disabled on your browser. - - - - - -Skip navigation links - - - - -Overview -Package -Class -Use -Tree -Deprecated -Index -Help - - - - -Prev -Next - - -Frames -NoFrames - - -AllClasses - - - - - - - - - - -Uses of Classorg.apache.hadoop.hbase.KeyValue.RawBytesComparator - -No usage of org.apache.hadoop.hbase.KeyValue.RawBytesComparator - - - - -Skip navigation links - - - - -Overview -Package -Class -Use -Tree -Deprecated -Index -Help - - - - -Prev -Next - - -Frames -NoFrames - - -AllClasses - - - - - -
[38/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/CellUtil.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/CellUtil.html b/devapidocs/org/apache/hadoop/hbase/CellUtil.html index 8c37a77..835b11f 100644 --- a/devapidocs/org/apache/hadoop/hbase/CellUtil.html +++ b/devapidocs/org/apache/hadoop/hbase/CellUtil.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":41,"i21":41,"i22":41,"i23":41,"i24":41,"i25":41,"i26":41,"i27":41,"i28":9,"i29":9,"i30":9,"i31":9,"i32":9,"i33":9,"i34":9,"i35":9,"i36":9,"i37":9,"i38":9,"i39":9,"i40":9,"i41":9,"i42":9,"i43":9,"i44":9,"i45":9,"i46":9,"i47":9,"i48":9,"i49":9,"i50":9,"i51":9,"i52":9,"i53":9,"i54":9,"i55":9,"i56":9,"i57":9,"i58":9,"i59":9,"i60":9,"i61":9,"i62":9,"i63":9,"i64":9,"i65":41,"i66":9,"i67":9,"i68":9,"i69":9,"i70":9,"i71":9,"i72":9,"i73":9,"i74":9,"i75":9,"i76":9,"i77":9,"i78":9,"i79":9,"i80":9,"i81":9,"i82":9,"i83":9,"i84":9,"i85":9,"i86":9,"i87":9,"i88":9,"i89":9,"i90":9,"i91":9,"i92":9,"i93":9,"i94":9,"i95":9,"i96":9,"i97":9,"i98":41,"i99":9,"i100":9,"i101":9,"i102":9,"i103":9,"i104":9,"i105":9,"i106":9,"i107":9,"i108":9,"i109":9,"i110":41,"i111":9,"i112":9,"i113":9,"i114":9,"i115":9,"i116":9,"i117":9,"i118":9,"i119":9," i120":9,"i121":9,"i122":9,"i123":9,"i124":9,"i125":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":41,"i21":41,"i22":41,"i23":41,"i24":41,"i25":41,"i26":41,"i27":41,"i28":9,"i29":9,"i30":9,"i31":9,"i32":9,"i33":9,"i34":9,"i35":9,"i36":9,"i37":9,"i38":9,"i39":9,"i40":9,"i41":9,"i42":9,"i43":9,"i44":9,"i45":9,"i46":9,"i47":9,"i48":9,"i49":9,"i50":9,"i51":9,"i52":9,"i53":9,"i54":9,"i55":9,"i56":9,"i57":9,"i58":9,"i59":9,"i60":9,"i61":9,"i62":9,"i63":9,"i64":9,"i65":41,"i66":9,"i67":9,"i68":9,"i69":9,"i70":9,"i71":9,"i72":9,"i73":9,"i74":9,"i75":9,"i76":9,"i77":9,"i78":9,"i79":9,"i80":9,"i81":9,"i82":9,"i83":9,"i84":9,"i85":9,"i86":9,"i87":9,"i88":9,"i89":9,"i90":9,"i91":9,"i92":9,"i93":9,"i94":9,"i95":9,"i96":9,"i97":9,"i98":9,"i99":41,"i100":9,"i101":9,"i102":9,"i103":9,"i104":9,"i105":9,"i106":9,"i107":9,"i108":9,"i109":9,"i110":9,"i111":9,"i112":41,"i113":9,"i114":9,"i115":9,"i116":9,"i117":9,"i118":9,"i119":9," i120":9,"i121":9,"i122":9,"i123":9,"i124":9,"i125":9,"i126":9,"i127":9}; var tabs = {65535:["t0","All Methods"],1:["t1","Static Methods"],8:["t4","Concrete Methods"],32:["t6","Deprecated Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -110,7 +110,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Public -public final class CellUtil +public final class CellUtil extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object Utility methods helpful slinging Cell instances. Some methods below are for internal use only and are marked InterfaceAudience.Private at the @@ -798,12 +798,19 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? isDeleteType(Cellcell) +static byte[] +makeColumn(byte[]family, + byte[]qualifier) +Makes a column in family:qualifier form from separate byte arrays. + + + static boolean matchingColumn(Cellleft, byte[]fam, byte[]qual) - + static boolean matchingColumn(Cellleft, byte[]fam, @@ -813,29 +820,29 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? intqoffset, intqlength) - + static boolean matchingColumn(Cellleft, Cellright) - + static boolean matchingFamily(Cellleft, byte[]buf) - + static boolean matchingFamily(Cellleft, byte[]buf, intoffset, intlength) - + static boolean matchingFamily(Cellleft, Cellright) - + static boolean matchingQualifier(Cellleft, byte[]buf) @@ -843,7 +850,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? byte[] are equal - + static boolean matchingQualifier(Cellleft, byte[]buf, @@ -853,24 +860,24 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? byte[] are equal - + static boolean matchingQualifier(Cellleft, Cellright) - + static boolean matchingRow(Cellleft, byte[]buf) - + static boolean matchingRow(Cellleft, byte[]buf, intoffset, intlength) - + static boolean matchingRow(Cellleft, Cellright) @@ -880,48 +887,48 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? - + static
[28/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/master/MasterCoprocessorHost.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/MasterCoprocessorHost.html b/devapidocs/org/apache/hadoop/hbase/master/MasterCoprocessorHost.html index c55db81..22db84d 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/MasterCoprocessorHost.html +++ b/devapidocs/org/apache/hadoop/hbase/master/MasterCoprocessorHost.html @@ -115,7 +115,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private -public class MasterCoprocessorHost +public class MasterCoprocessorHost extends CoprocessorHostMasterCoprocessor,MasterCoprocessorEnvironment Provides the coprocessor framework and environment for master oriented operations. HMaster interacts with the loaded coprocessors @@ -979,7 +979,7 @@ extends LOG -private static finalorg.apache.commons.logging.Log LOG +private static finalorg.apache.commons.logging.Log LOG @@ -988,7 +988,7 @@ extends masterServices -privateMasterServices masterServices +privateMasterServices masterServices @@ -997,7 +997,7 @@ extends masterObserverGetter -privateCoprocessorHost.ObserverGetterMasterCoprocessor,MasterObserver masterObserverGetter +privateCoprocessorHost.ObserverGetterMasterCoprocessor,MasterObserver masterObserverGetter @@ -1014,7 +1014,7 @@ extends MasterCoprocessorHost -publicMasterCoprocessorHost(MasterServicesservices, +publicMasterCoprocessorHost(MasterServicesservices, org.apache.hadoop.conf.Configurationconf) @@ -1032,7 +1032,7 @@ extends createEnvironment -publicMasterCoprocessorHost.MasterEnvironmentcreateEnvironment(MasterCoprocessorinstance, +publicMasterCoprocessorHost.MasterEnvironmentcreateEnvironment(MasterCoprocessorinstance, intpriority, intseq, org.apache.hadoop.conf.Configurationconf) @@ -1050,7 +1050,7 @@ extends checkAndGetInstance -publicMasterCoprocessorcheckAndGetInstance(http://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true; title="class or interface in java.lang">Class?implClass) +publicMasterCoprocessorcheckAndGetInstance(http://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true; title="class or interface in java.lang">Class?implClass) throws http://docs.oracle.com/javase/8/docs/api/java/lang/InstantiationException.html?is-external=true; title="class or interface in java.lang">InstantiationException, http://docs.oracle.com/javase/8/docs/api/java/lang/IllegalAccessException.html?is-external=true; title="class or interface in java.lang">IllegalAccessException Description copied from class:CoprocessorHost @@ -1074,7 +1074,7 @@ extends preCreateNamespace -publicbooleanpreCreateNamespace(NamespaceDescriptorns) +publicbooleanpreCreateNamespace(NamespaceDescriptorns) 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: @@ -1088,7 +1088,7 @@ extends postCreateNamespace -publicvoidpostCreateNamespace(NamespaceDescriptorns) +publicvoidpostCreateNamespace(NamespaceDescriptorns) 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: @@ -1102,7 +1102,7 @@ extends preDeleteNamespace -publicbooleanpreDeleteNamespace(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringnamespaceName) +publicbooleanpreDeleteNamespace(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringnamespaceName) 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: @@ -1116,7 +1116,7 @@ extends postDeleteNamespace -publicvoidpostDeleteNamespace(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringnamespaceName) +publicvoidpostDeleteNamespace(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringnamespaceName) 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: @@ -1130,7 +1130,7 @@ extends preModifyNamespace
[46/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/apidocs/src-html/org/apache/hadoop/hbase/TableName.html -- diff --git a/apidocs/src-html/org/apache/hadoop/hbase/TableName.html b/apidocs/src-html/org/apache/hadoop/hbase/TableName.html index c31340b..e809a27 100644 --- a/apidocs/src-html/org/apache/hadoop/hbase/TableName.html +++ b/apidocs/src-html/org/apache/hadoop/hbase/TableName.html @@ -34,532 +34,516 @@ 026 027import org.apache.yetus.audience.InterfaceAudience; 028import org.apache.hadoop.hbase.util.Bytes; -029import org.apache.hadoop.hbase.KeyValue.KVComparator; -030 -031/** -032 * Immutable POJO class for representing a table name. -033 * Which is of the form: -034 * lt;table namespacegt;:lt;table qualifiergt; -035 * -036 * Two special namespaces: -037 * -038 * 1. hbase - system namespace, used to contain hbase internal tables -039 * 2. default - tables with no explicit specified namespace will -040 * automatically fall into this namespace. -041 * -042 * ie -043 * -044 * a) foo:bar, means namespace=foo and qualifier=bar -045 * b) bar, means namespace=default and qualifier=bar -046 * c) default:bar, means namespace=default and qualifier=bar -047 * -048 * p -049 * Internally, in this class, we cache the instances to limit the number of objects and -050 * make the "equals" faster. We try to minimize the number of objects created of -051 * the number of array copy to check if we already have an instance of this TableName. The code -052 * is not optimize for a new instance creation but is optimized to check for existence. -053 * /p -054 */ -055@InterfaceAudience.Public -056public final class TableName implements ComparableTableName { -057 -058 /** See {@link #createTableNameIfNecessary(ByteBuffer, ByteBuffer)} */ -059 private static final SetTableName tableCache = new CopyOnWriteArraySet(); -060 -061 /** Namespace delimiter */ -062 //this should always be only 1 byte long -063 public final static char NAMESPACE_DELIM = ':'; -064 -065 // A non-capture group so that this can be embedded. -066 // regex is a bit more complicated to support nuance of tables -067 // in default namespace -068 //Allows only letters, digits and '_' -069 public static final String VALID_NAMESPACE_REGEX = -070 "(?:[_\\p{Digit}\\p{IsAlphabetic}]+)"; -071 //Allows only letters, digits, '_', '-' and '.' -072 public static final String VALID_TABLE_QUALIFIER_REGEX = -073 "(?:[_\\p{Digit}\\p{IsAlphabetic}][-_.\\p{Digit}\\p{IsAlphabetic}]*)"; -074 //Concatenation of NAMESPACE_REGEX and TABLE_QUALIFIER_REGEX, -075 //with NAMESPACE_DELIM as delimiter -076 public static final String VALID_USER_TABLE_REGEX = -077 "(?:(?:(?:"+VALID_NAMESPACE_REGEX+"\\"+NAMESPACE_DELIM+")?)" + -078 "(?:"+VALID_TABLE_QUALIFIER_REGEX+"))"; -079 -080 /** The hbase:meta table's name. */ -081 public static final TableName META_TABLE_NAME = -082 valueOf(NamespaceDescriptor.SYSTEM_NAMESPACE_NAME_STR, "meta"); -083 -084 /** The Namespace table's name. */ -085 public static final TableName NAMESPACE_TABLE_NAME = -086 valueOf(NamespaceDescriptor.SYSTEM_NAMESPACE_NAME_STR, "namespace"); -087 -088 public static final String OLD_META_STR = ".META."; -089 public static final String OLD_ROOT_STR = "-ROOT-"; -090 -091 /** One globally disallowed name */ -092 public static final String DISALLOWED_TABLE_NAME = "zookeeper"; -093 -094 /** -095 * @return True if codetn/code is the hbase:meta table name. -096 */ -097 public static boolean isMetaTableName(final TableName tn) { -098return tn.equals(TableName.META_TABLE_NAME); -099 } -100 -101 /** -102 * TableName for old -ROOT- table. It is used to read/process old WALs which have -103 * ROOT edits. -104 */ -105 public static final TableName OLD_ROOT_TABLE_NAME = getADummyTableName(OLD_ROOT_STR); -106 /** -107 * TableName for old .META. table. Used in testing. -108 */ -109 public static final TableName OLD_META_TABLE_NAME = getADummyTableName(OLD_META_STR); -110 -111 private final byte[] name; -112 private final String nameAsString; -113 private final byte[] namespace; -114 private final String namespaceAsString; -115 private final byte[] qualifier; -116 private final String qualifierAsString; -117 private final boolean systemTable; -118 private final int hashCode; -119 -120 /** -121 * Check passed byte array, "tableName", is legal user-space table name. -122 * @return Returns passed codetableName/code param -123 * @throws IllegalArgumentException if passed a tableName is null or -124 * is made of other than 'word' characters or underscores: i.e. -125 * code[\p{IsAlphabetic}\p{Digit}.-:]/code. The ':' is used to delimit the namespace -126 * from the table name and can be used for nothing else. -127 * -128 * Namespace names can only contain 'word' characters -129 *
[32/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.DeleteCommand.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.DeleteCommand.html b/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.DeleteCommand.html index 0edbf3d..84a1ee5 100644 --- a/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.DeleteCommand.html +++ b/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.DeleteCommand.html @@ -127,7 +127,7 @@ var activeTableTab = "activeTableTab"; -private static class BackupCommands.DeleteCommand +private static class BackupCommands.DeleteCommand extends BackupCommands.Command @@ -236,7 +236,7 @@ extends DeleteCommand -DeleteCommand(org.apache.hadoop.conf.Configurationconf, +DeleteCommand(org.apache.hadoop.conf.Configurationconf, org.apache.commons.cli.CommandLinecmdline) @@ -254,7 +254,7 @@ extends requiresNoActiveSession -protectedbooleanrequiresNoActiveSession() +protectedbooleanrequiresNoActiveSession() Description copied from class:BackupCommands.Command The command can't be run if active backup session is in progress @@ -271,7 +271,7 @@ extends 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 Overrides: @@ -287,7 +287,7 @@ extends printUsage -protectedvoidprintUsage() +protectedvoidprintUsage() Specified by: printUsagein classBackupCommands.Command http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.DescribeCommand.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.DescribeCommand.html b/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.DescribeCommand.html index e2f5d70..6d6c3e2 100644 --- a/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.DescribeCommand.html +++ b/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.DescribeCommand.html @@ -127,7 +127,7 @@ var activeTableTab = "activeTableTab"; -private static class BackupCommands.DescribeCommand +private static class BackupCommands.DescribeCommand extends BackupCommands.Command @@ -230,7 +230,7 @@ extends DescribeCommand -DescribeCommand(org.apache.hadoop.conf.Configurationconf, +DescribeCommand(org.apache.hadoop.conf.Configurationconf, org.apache.commons.cli.CommandLinecmdline) @@ -248,7 +248,7 @@ extends 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 Overrides: @@ -264,7 +264,7 @@ extends printUsage -protectedvoidprintUsage() +protectedvoidprintUsage() Specified by: printUsagein classBackupCommands.Command http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.HelpCommand.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.HelpCommand.html b/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.HelpCommand.html index 69eb817..4daa031 100644 --- a/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.HelpCommand.html +++ b/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.HelpCommand.html @@ -127,7 +127,7 @@ var activeTableTab = "activeTableTab"; -private static class BackupCommands.HelpCommand +private static class BackupCommands.HelpCommand extends BackupCommands.Command @@ -230,7 +230,7 @@ extends HelpCommand -HelpCommand(org.apache.hadoop.conf.Configurationconf, +HelpCommand(org.apache.hadoop.conf.Configurationconf, org.apache.commons.cli.CommandLinecmdline) @@ -248,7 +248,7 @@ extends 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 Overrides: @@ -264,7 +264,7 @@ extends printUsage -protectedvoidprintUsage() +protectedvoidprintUsage() Specified by: printUsagein classBackupCommands.Command http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.HistoryCommand.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.HistoryCommand.html b/devapidocs/org/apache/hadoop/hbase/backup/impl/BackupCommands.HistoryCommand.html index 30ba9e8..377a138
[18/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyCell.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyCell.html index 26125e3..eb6a00d 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyCell.html @@ -28,3193 +28,3241 @@ 020 021import static org.apache.hadoop.hbase.HConstants.EMPTY_BYTE_ARRAY; 022import static org.apache.hadoop.hbase.Tag.TAG_LENGTH_SIZE; -023 -024import java.io.DataOutputStream; -025import java.io.IOException; -026import java.io.OutputStream; -027import java.math.BigDecimal; -028import java.nio.ByteBuffer; -029import java.util.ArrayList; -030import java.util.Arrays; -031import java.util.Iterator; -032import java.util.List; -033import java.util.Map.Entry; -034import java.util.NavigableMap; -035 -036import org.apache.hadoop.hbase.KeyValue.Type; -037import org.apache.yetus.audience.InterfaceAudience; -038import org.apache.yetus.audience.InterfaceAudience.Private; -039import org.apache.hadoop.hbase.io.HeapSize; -040import org.apache.hadoop.hbase.io.TagCompressionContext; -041import org.apache.hadoop.hbase.io.util.Dictionary; -042import org.apache.hadoop.hbase.io.util.StreamUtils; -043import org.apache.hadoop.hbase.util.ByteBufferUtils; -044import org.apache.hadoop.hbase.util.ByteRange; -045import org.apache.hadoop.hbase.util.Bytes; -046import org.apache.hadoop.hbase.util.ClassSize; -047 -048/** -049 * Utility methods helpful slinging {@link Cell} instances. -050 * Some methods below are for internal use only and are marked InterfaceAudience.Private at the -051 * method level. -052 */ -053@InterfaceAudience.Public -054public final class CellUtil { -055 -056 /** -057 * Private constructor to keep this class from being instantiated. -058 */ -059 private CellUtil(){} -060 -061 /*** ByteRange ***/ -062 -063 public static ByteRange fillRowRange(Cell cell, ByteRange range) { -064return range.set(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()); -065 } -066 -067 public static ByteRange fillFamilyRange(Cell cell, ByteRange range) { -068return range.set(cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength()); -069 } -070 -071 public static ByteRange fillQualifierRange(Cell cell, ByteRange range) { -072return range.set(cell.getQualifierArray(), cell.getQualifierOffset(), -073 cell.getQualifierLength()); -074 } -075 -076 public static ByteRange fillValueRange(Cell cell, ByteRange range) { -077return range.set(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength()); -078 } -079 -080 public static ByteRange fillTagRange(Cell cell, ByteRange range) { -081return range.set(cell.getTagsArray(), cell.getTagsOffset(), cell.getTagsLength()); -082 } -083 -084 /* get individual arrays for tests / -085 -086 public static byte[] cloneRow(Cell cell){ -087byte[] output = new byte[cell.getRowLength()]; -088copyRowTo(cell, output, 0); -089return output; -090 } -091 -092 public static byte[] cloneFamily(Cell cell){ -093byte[] output = new byte[cell.getFamilyLength()]; -094copyFamilyTo(cell, output, 0); -095return output; -096 } -097 -098 public static byte[] cloneQualifier(Cell cell){ -099byte[] output = new byte[cell.getQualifierLength()]; -100copyQualifierTo(cell, output, 0); -101return output; -102 } -103 -104 public static byte[] cloneValue(Cell cell){ -105byte[] output = new byte[cell.getValueLength()]; -106copyValueTo(cell, output, 0); -107return output; -108 } -109 -110 public static byte[] cloneTags(Cell cell) { -111byte[] output = new byte[cell.getTagsLength()]; -112copyTagTo(cell, output, 0); -113return output; -114 } -115 -116 /** -117 * Returns tag value in a new byte array. If server-side, use -118 * {@link Tag#getValueArray()} with appropriate {@link Tag#getValueOffset()} and -119 * {@link Tag#getValueLength()} instead to save on allocations. -120 * @param cell -121 * @return tag value in a new byte array. -122 */ -123 public static byte[] getTagArray(Cell cell){ -124byte[] output = new byte[cell.getTagsLength()]; -125copyTagTo(cell, output, 0); -126return output; -127 } -128 -129 -130 / copyTo **/ +023import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIMITER; +024import static org.apache.hadoop.hbase.KeyValue.getDelimiter; +025import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIM_ARRAY; +026 +027import java.io.DataOutputStream; +028import java.io.IOException; +029import java.io.OutputStream;
[39/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/CellUtil.ValueAndTagRewriteByteBufferCell.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/CellUtil.ValueAndTagRewriteByteBufferCell.html b/devapidocs/org/apache/hadoop/hbase/CellUtil.ValueAndTagRewriteByteBufferCell.html index 302d56d..bb46f68 100644 --- a/devapidocs/org/apache/hadoop/hbase/CellUtil.ValueAndTagRewriteByteBufferCell.html +++ b/devapidocs/org/apache/hadoop/hbase/CellUtil.ValueAndTagRewriteByteBufferCell.html @@ -128,7 +128,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private -private static class CellUtil.ValueAndTagRewriteByteBufferCell +private static class CellUtil.ValueAndTagRewriteByteBufferCell extends CellUtil.TagRewriteByteBufferCell @@ -292,7 +292,7 @@ extends value -protectedbyte[] value +protectedbyte[] value @@ -309,7 +309,7 @@ extends ValueAndTagRewriteByteBufferCell -publicValueAndTagRewriteByteBufferCell(ByteBufferCellcell, +publicValueAndTagRewriteByteBufferCell(ByteBufferCellcell, byte[]value, byte[]tags) @@ -328,7 +328,7 @@ extends getValueArray -publicbyte[]getValueArray() +publicbyte[]getValueArray() Description copied from interface:Cell Contiguous raw bytes that may start at any index in the containing array. Max length is Integer.MAX_VALUE which is 2,147,483,647 bytes. @@ -348,7 +348,7 @@ extends getValueOffset -publicintgetValueOffset() +publicintgetValueOffset() Specified by: getValueOffsetin interfaceCell @@ -365,7 +365,7 @@ extends getValueLength -publicintgetValueLength() +publicintgetValueLength() Specified by: getValueLengthin interfaceCell @@ -382,7 +382,7 @@ extends getValueByteBuffer -publichttp://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true; title="class or interface in java.nio">ByteBuffergetValueByteBuffer() +publichttp://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true; title="class or interface in java.nio">ByteBuffergetValueByteBuffer() Overrides: getValueByteBufferin classCellUtil.TagRewriteByteBufferCell @@ -397,7 +397,7 @@ extends getValuePosition -publicintgetValuePosition() +publicintgetValuePosition() Overrides: getValuePositionin classCellUtil.TagRewriteByteBufferCell @@ -412,7 +412,7 @@ extends heapSize -publiclongheapSize() +publiclongheapSize() Specified by: heapSizein interfaceHeapSize @@ -430,7 +430,7 @@ extends write -publicintwrite(http://docs.oracle.com/javase/8/docs/api/java/io/OutputStream.html?is-external=true; title="class or interface in java.io">OutputStreamout, +publicintwrite(http://docs.oracle.com/javase/8/docs/api/java/io/OutputStream.html?is-external=true; title="class or interface in java.io">OutputStreamout, booleanwithTags) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Description copied from interface:ExtendedCell @@ -461,7 +461,7 @@ extends getSerializedSize -publicintgetSerializedSize(booleanwithTags) +publicintgetSerializedSize(booleanwithTags) Specified by: getSerializedSizein interfaceExtendedCell @@ -485,7 +485,7 @@ extends write -publicvoidwrite(http://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true; title="class or interface in java.nio">ByteBufferbuf, +publicvoidwrite(http://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true; title="class or interface in java.nio">ByteBufferbuf, intoffset) Description copied from interface:ExtendedCell Write this Cell into the given buf's offset in a KeyValue format. @@ -506,7 +506,7 @@ extends deepClone -publicExtendedCelldeepClone() +publicExtendedCelldeepClone() Description copied from interface:ExtendedCell Does a deep copy of the contents to a new memory area and returns it as a new cell. http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/CellUtil.ValueAndTagRewriteCell.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/CellUtil.ValueAndTagRewriteCell.html b/devapidocs/org/apache/hadoop/hbase/CellUtil.ValueAndTagRewriteCell.html index c35d0ae..540c5b1 100644 --- a/devapidocs/org/apache/hadoop/hbase/CellUtil.ValueAndTagRewriteCell.html +++ b/devapidocs/org/apache/hadoop/hbase/CellUtil.ValueAndTagRewriteCell.html @@ -123,7 +123,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private -private static class CellUtil.ValueAndTagRewriteCell +private static class CellUtil.ValueAndTagRewriteCell extends CellUtil.TagRewriteCell @@ -295,7 +295,7 @@ extends value -protectedbyte[] value
[17/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowByteBufferCell.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowByteBufferCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowByteBufferCell.html index 26125e3..eb6a00d 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowByteBufferCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowByteBufferCell.html @@ -28,3193 +28,3241 @@ 020 021import static org.apache.hadoop.hbase.HConstants.EMPTY_BYTE_ARRAY; 022import static org.apache.hadoop.hbase.Tag.TAG_LENGTH_SIZE; -023 -024import java.io.DataOutputStream; -025import java.io.IOException; -026import java.io.OutputStream; -027import java.math.BigDecimal; -028import java.nio.ByteBuffer; -029import java.util.ArrayList; -030import java.util.Arrays; -031import java.util.Iterator; -032import java.util.List; -033import java.util.Map.Entry; -034import java.util.NavigableMap; -035 -036import org.apache.hadoop.hbase.KeyValue.Type; -037import org.apache.yetus.audience.InterfaceAudience; -038import org.apache.yetus.audience.InterfaceAudience.Private; -039import org.apache.hadoop.hbase.io.HeapSize; -040import org.apache.hadoop.hbase.io.TagCompressionContext; -041import org.apache.hadoop.hbase.io.util.Dictionary; -042import org.apache.hadoop.hbase.io.util.StreamUtils; -043import org.apache.hadoop.hbase.util.ByteBufferUtils; -044import org.apache.hadoop.hbase.util.ByteRange; -045import org.apache.hadoop.hbase.util.Bytes; -046import org.apache.hadoop.hbase.util.ClassSize; -047 -048/** -049 * Utility methods helpful slinging {@link Cell} instances. -050 * Some methods below are for internal use only and are marked InterfaceAudience.Private at the -051 * method level. -052 */ -053@InterfaceAudience.Public -054public final class CellUtil { -055 -056 /** -057 * Private constructor to keep this class from being instantiated. -058 */ -059 private CellUtil(){} -060 -061 /*** ByteRange ***/ -062 -063 public static ByteRange fillRowRange(Cell cell, ByteRange range) { -064return range.set(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()); -065 } -066 -067 public static ByteRange fillFamilyRange(Cell cell, ByteRange range) { -068return range.set(cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength()); -069 } -070 -071 public static ByteRange fillQualifierRange(Cell cell, ByteRange range) { -072return range.set(cell.getQualifierArray(), cell.getQualifierOffset(), -073 cell.getQualifierLength()); -074 } -075 -076 public static ByteRange fillValueRange(Cell cell, ByteRange range) { -077return range.set(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength()); -078 } -079 -080 public static ByteRange fillTagRange(Cell cell, ByteRange range) { -081return range.set(cell.getTagsArray(), cell.getTagsOffset(), cell.getTagsLength()); -082 } -083 -084 /* get individual arrays for tests / -085 -086 public static byte[] cloneRow(Cell cell){ -087byte[] output = new byte[cell.getRowLength()]; -088copyRowTo(cell, output, 0); -089return output; -090 } -091 -092 public static byte[] cloneFamily(Cell cell){ -093byte[] output = new byte[cell.getFamilyLength()]; -094copyFamilyTo(cell, output, 0); -095return output; -096 } -097 -098 public static byte[] cloneQualifier(Cell cell){ -099byte[] output = new byte[cell.getQualifierLength()]; -100copyQualifierTo(cell, output, 0); -101return output; -102 } -103 -104 public static byte[] cloneValue(Cell cell){ -105byte[] output = new byte[cell.getValueLength()]; -106copyValueTo(cell, output, 0); -107return output; -108 } -109 -110 public static byte[] cloneTags(Cell cell) { -111byte[] output = new byte[cell.getTagsLength()]; -112copyTagTo(cell, output, 0); -113return output; -114 } -115 -116 /** -117 * Returns tag value in a new byte array. If server-side, use -118 * {@link Tag#getValueArray()} with appropriate {@link Tag#getValueOffset()} and -119 * {@link Tag#getValueLength()} instead to save on allocations. -120 * @param cell -121 * @return tag value in a new byte array. -122 */ -123 public static byte[] getTagArray(Cell cell){ -124byte[] output = new byte[cell.getTagsLength()]; -125copyTagTo(cell, output, 0); -126return output; -127 } -128 -129 -130 / copyTo **/ +023import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIMITER; +024import static org.apache.hadoop.hbase.KeyValue.getDelimiter; +025import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIM_ARRAY; +026 +027import
[36/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/KeyValue.MetaComparator.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/KeyValue.MetaComparator.html b/devapidocs/org/apache/hadoop/hbase/KeyValue.MetaComparator.html index a4a5297..f918008 100644 --- a/devapidocs/org/apache/hadoop/hbase/KeyValue.MetaComparator.html +++ b/devapidocs/org/apache/hadoop/hbase/KeyValue.MetaComparator.html @@ -50,7 +50,7 @@ var activeTableTab = "activeTableTab"; PrevClass -NextClass +NextClass Frames @@ -122,11 +122,11 @@ var activeTableTab = "activeTableTab"; Deprecated. -: CellComparator.META_COMPARATOR to be used +: CellComparator.META_COMPARATOR to be used. Deprecated for hbase 2.0, remove for hbase 3.0. http://docs.oracle.com/javase/8/docs/api/java/lang/Deprecated.html?is-external=true; title="class or interface in java.lang">@Deprecated -public static class KeyValue.MetaComparator +public static class KeyValue.MetaComparator extends KeyValue.KVComparator A KeyValue.KVComparator for hbase:meta catalog table KeyValues. @@ -266,7 +266,7 @@ extends MetaComparator -publicMetaComparator() +publicMetaComparator() Deprecated. @@ -284,7 +284,7 @@ extends compare -publicintcompare(Cellleft, +publicintcompare(Cellleft, Cellright) Deprecated. Compare key portion of a KeyValue for keys in hbase:meta @@ -303,7 +303,7 @@ extends compareOnlyKeyPortion -publicintcompareOnlyKeyPortion(Cellleft, +publicintcompareOnlyKeyPortion(Cellleft, Cellright) Deprecated. @@ -318,7 +318,7 @@ extends compareRows -publicintcompareRows(byte[]left, +publicintcompareRows(byte[]left, intloffset, intllength, byte[]right, @@ -341,7 +341,7 @@ extends getShortMidpointKey -publicbyte[]getShortMidpointKey(byte[]leftKey, +publicbyte[]getShortMidpointKey(byte[]leftKey, byte[]rightKey) Deprecated. Don't do any fancy Block Index splitting tricks. @@ -359,7 +359,7 @@ extends getLegacyKeyComparatorName -publichttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringgetLegacyKeyComparatorName() +publichttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringgetLegacyKeyComparatorName() Deprecated. The HFileV2 file format's trailer contains this class name. We reinterpret this and instantiate the appropriate comparator. @@ -378,7 +378,7 @@ extends clone -protectedhttp://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Objectclone() +protectedhttp://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Objectclone() throws http://docs.oracle.com/javase/8/docs/api/java/lang/CloneNotSupportedException.html?is-external=true; title="class or interface in java.lang">CloneNotSupportedException Deprecated. @@ -395,7 +395,7 @@ extends compareRowKey -protectedintcompareRowKey(Celll, +protectedintcompareRowKey(Celll, Cellr) Deprecated. Override the row key comparison to parse and compare the meta row key parts. @@ -436,7 +436,7 @@ extends PrevClass -NextClass +NextClass Frames http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/KeyValue.RawBytesComparator.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/KeyValue.RawBytesComparator.html b/devapidocs/org/apache/hadoop/hbase/KeyValue.RawBytesComparator.html deleted file mode 100644 index e51c45a..000 --- a/devapidocs/org/apache/hadoop/hbase/KeyValue.RawBytesComparator.html +++ /dev/null @@ -1,430 +0,0 @@ -http://www.w3.org/TR/html4/loose.dtd;> - - - - - -KeyValue.RawBytesComparator (Apache HBase 3.0.0-SNAPSHOT API) - - - - - -var methods = {"i0":42,"i1":42,"i2":42,"i3":42,"i4":42}; -var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"],32:["t6","Deprecated Methods"]}; -var altColor = "altColor"; -var rowColor = "rowColor"; -var tableTab = "tableTab"; -var activeTableTab = "activeTableTab"; - - -JavaScript is disabled on your browser. - - - - - -Skip navigation links - - - - -Overview -Package -Class -Use -Tree -Deprecated -Index -Help - - - - -PrevClass -NextClass - - -Frames -NoFrames - - -AllClasses - - - -var methods = {"i0":10,"i1":9,"i2":10,"i3":9,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":42,"i12":10,"i13":9,"i14":9,"i15":9,"i16":9,"i17":9,"i18":9,"i19":9,"i20":9,"i21":10,"i22":10,"i23":10,"i24":9,"i25":9,"i26":9,"i27":9,"i28":9}; -var tabs = {65535:["t0","All Methods"],1:["t1","Static Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"],32:["t6","Deprecated Methods"]}; +var methods = {"i0":10,"i1":9,"i2":10,"i3":9,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":9,"i13":9,"i14":9,"i15":9,"i16":9,"i17":9,"i18":9,"i19":9,"i20":10,"i21":10,"i22":10,"i23":9,"i24":9,"i25":9,"i26":9,"i27":9}; +var tabs = {65535:["t0","All Methods"],1:["t1","Static Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; var tableTab = "tableTab"; @@ -114,7 +114,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Public -public final class TableName +public final class TableName 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 http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableTableName Immutable POJO class for representing a table name. @@ -287,7 +287,7 @@ implements http://docs.oracle.com/javase/8/docs/api/java/lang/Comparabl Method Summary -All MethodsStatic MethodsInstance MethodsConcrete MethodsDeprecated Methods +All MethodsStatic MethodsInstance MethodsConcrete Methods Modifier and Type Method and Description @@ -347,29 +347,20 @@ implements http://docs.oracle.com/javase/8/docs/api/java/lang/Comparabl getQualifierAsString() -KeyValue.KVComparator -getRowComparator() -Deprecated. -The comparator is an internal property of the table. Should - not have been exposed here - - - - int hashCode() - + static byte[] isLegalFullyQualifiedTableName(byte[]tableName) Check passed byte array, "tableName", is legal user-space table name. - + static void isLegalNamespaceName(byte[]namespaceName) - + static void isLegalNamespaceName(byte[]namespaceName, intstart, @@ -377,16 +368,16 @@ implements http://docs.oracle.com/javase/8/docs/api/java/lang/Comparabl Valid namespace characters are alphabetic characters, numbers, and underscores. - + static byte[] isLegalTableQualifierName(byte[]qualifierName) - + static byte[] isLegalTableQualifierName(byte[]qualifierName, booleanisSnapshot) - + static void isLegalTableQualifierName(byte[]qualifierName, intstart, @@ -395,48 +386,48 @@ implements http://docs.oracle.com/javase/8/docs/api/java/lang/Comparabl [\p{IsAlphabetic}\p{Digit}] or '_', '.' or '-'. - + static void isLegalTableQualifierName(byte[]qualifierName, intstart, intend, booleanisSnapshot) - + static boolean isMetaTableName(TableNametn) - + boolean isSystemTable() - + byte[] toBytes() - + http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String toString() - + static TableName valueOf(byte[]fullName) - + static TableName valueOf(byte[]namespace, byte[]qualifier) - + static TableName valueOf(http://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true; title="class or interface in java.nio">ByteBuffernamespace, http://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true; title="class or interface in java.nio">ByteBufferqualifier) - + static TableName valueOf(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) - + static TableName valueOf(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringnamespaceAsString, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringqualifierAsString) @@ -469,7 +460,7 @@ implements http://docs.oracle.com/javase/8/docs/api/java/lang/Comparabl tableCache -private static finalhttp://docs.oracle.com/javase/8/docs/api/java/util/Set.html?is-external=true; title="class or interface in
[04/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.ValueAndTagRewriteByteBufferCell.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.ValueAndTagRewriteByteBufferCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.ValueAndTagRewriteByteBufferCell.html index 26125e3..eb6a00d 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.ValueAndTagRewriteByteBufferCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.ValueAndTagRewriteByteBufferCell.html @@ -28,3193 +28,3241 @@ 020 021import static org.apache.hadoop.hbase.HConstants.EMPTY_BYTE_ARRAY; 022import static org.apache.hadoop.hbase.Tag.TAG_LENGTH_SIZE; -023 -024import java.io.DataOutputStream; -025import java.io.IOException; -026import java.io.OutputStream; -027import java.math.BigDecimal; -028import java.nio.ByteBuffer; -029import java.util.ArrayList; -030import java.util.Arrays; -031import java.util.Iterator; -032import java.util.List; -033import java.util.Map.Entry; -034import java.util.NavigableMap; -035 -036import org.apache.hadoop.hbase.KeyValue.Type; -037import org.apache.yetus.audience.InterfaceAudience; -038import org.apache.yetus.audience.InterfaceAudience.Private; -039import org.apache.hadoop.hbase.io.HeapSize; -040import org.apache.hadoop.hbase.io.TagCompressionContext; -041import org.apache.hadoop.hbase.io.util.Dictionary; -042import org.apache.hadoop.hbase.io.util.StreamUtils; -043import org.apache.hadoop.hbase.util.ByteBufferUtils; -044import org.apache.hadoop.hbase.util.ByteRange; -045import org.apache.hadoop.hbase.util.Bytes; -046import org.apache.hadoop.hbase.util.ClassSize; -047 -048/** -049 * Utility methods helpful slinging {@link Cell} instances. -050 * Some methods below are for internal use only and are marked InterfaceAudience.Private at the -051 * method level. -052 */ -053@InterfaceAudience.Public -054public final class CellUtil { -055 -056 /** -057 * Private constructor to keep this class from being instantiated. -058 */ -059 private CellUtil(){} -060 -061 /*** ByteRange ***/ -062 -063 public static ByteRange fillRowRange(Cell cell, ByteRange range) { -064return range.set(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()); -065 } -066 -067 public static ByteRange fillFamilyRange(Cell cell, ByteRange range) { -068return range.set(cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength()); -069 } -070 -071 public static ByteRange fillQualifierRange(Cell cell, ByteRange range) { -072return range.set(cell.getQualifierArray(), cell.getQualifierOffset(), -073 cell.getQualifierLength()); -074 } -075 -076 public static ByteRange fillValueRange(Cell cell, ByteRange range) { -077return range.set(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength()); -078 } -079 -080 public static ByteRange fillTagRange(Cell cell, ByteRange range) { -081return range.set(cell.getTagsArray(), cell.getTagsOffset(), cell.getTagsLength()); -082 } -083 -084 /* get individual arrays for tests / -085 -086 public static byte[] cloneRow(Cell cell){ -087byte[] output = new byte[cell.getRowLength()]; -088copyRowTo(cell, output, 0); -089return output; -090 } -091 -092 public static byte[] cloneFamily(Cell cell){ -093byte[] output = new byte[cell.getFamilyLength()]; -094copyFamilyTo(cell, output, 0); -095return output; -096 } -097 -098 public static byte[] cloneQualifier(Cell cell){ -099byte[] output = new byte[cell.getQualifierLength()]; -100copyQualifierTo(cell, output, 0); -101return output; -102 } -103 -104 public static byte[] cloneValue(Cell cell){ -105byte[] output = new byte[cell.getValueLength()]; -106copyValueTo(cell, output, 0); -107return output; -108 } -109 -110 public static byte[] cloneTags(Cell cell) { -111byte[] output = new byte[cell.getTagsLength()]; -112copyTagTo(cell, output, 0); -113return output; -114 } -115 -116 /** -117 * Returns tag value in a new byte array. If server-side, use -118 * {@link Tag#getValueArray()} with appropriate {@link Tag#getValueOffset()} and -119 * {@link Tag#getValueLength()} instead to save on allocations. -120 * @param cell -121 * @return tag value in a new byte array. -122 */ -123 public static byte[] getTagArray(Cell cell){ -124byte[] output = new byte[cell.getTagsLength()]; -125copyTagTo(cell, output, 0); -126return output; -127 } -128 -129 -130 / copyTo **/ +023import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIMITER; +024import static org.apache.hadoop.hbase.KeyValue.getDelimiter; +025import static
[21/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/thrift/ThriftServerRunner.HBaseHandler.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/thrift/ThriftServerRunner.HBaseHandler.html b/devapidocs/org/apache/hadoop/hbase/thrift/ThriftServerRunner.HBaseHandler.html index f8c4592..ac80981 100644 --- a/devapidocs/org/apache/hadoop/hbase/thrift/ThriftServerRunner.HBaseHandler.html +++ b/devapidocs/org/apache/hadoop/hbase/thrift/ThriftServerRunner.HBaseHandler.html @@ -117,7 +117,7 @@ var activeTableTab = "activeTableTab"; -public static class ThriftServerRunner.HBaseHandler +public static class ThriftServerRunner.HBaseHandler 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 org.apache.hadoop.hbase.thrift.generated.Hbase.Iface The HBaseHandler is a glue object that connects Thrift RPC calls to the @@ -721,7 +721,7 @@ implements org.apache.hadoop.hbase.thrift.generated.Hbase.Iface conf -protectedorg.apache.hadoop.conf.Configuration conf +protectedorg.apache.hadoop.conf.Configuration conf @@ -730,7 +730,7 @@ implements org.apache.hadoop.hbase.thrift.generated.Hbase.Iface LOG -protected static finalorg.apache.commons.logging.Log LOG +protected static finalorg.apache.commons.logging.Log LOG @@ -739,7 +739,7 @@ implements org.apache.hadoop.hbase.thrift.generated.Hbase.Iface nextScannerId -protectedint nextScannerId +protectedint nextScannerId @@ -748,7 +748,7 @@ implements org.apache.hadoop.hbase.thrift.generated.Hbase.Iface scannerMap -protectedhttp://docs.oracle.com/javase/8/docs/api/java/util/HashMap.html?is-external=true; title="class or interface in java.util">HashMaphttp://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true; title="class or interface in java.lang">Integer,ThriftServerRunner.ResultScannerWrapper scannerMap +protectedhttp://docs.oracle.com/javase/8/docs/api/java/util/HashMap.html?is-external=true; title="class or interface in java.util">HashMaphttp://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true; title="class or interface in java.lang">Integer,ThriftServerRunner.ResultScannerWrapper scannerMap @@ -757,7 +757,7 @@ implements org.apache.hadoop.hbase.thrift.generated.Hbase.Iface metrics -privateThriftMetrics metrics +privateThriftMetrics metrics @@ -766,7 +766,7 @@ implements org.apache.hadoop.hbase.thrift.generated.Hbase.Iface connectionCache -private finalConnectionCache connectionCache +private finalConnectionCache connectionCache @@ -775,7 +775,7 @@ implements org.apache.hadoop.hbase.thrift.generated.Hbase.Iface coalescer -IncrementCoalescer coalescer +IncrementCoalescer coalescer @@ -784,7 +784,7 @@ implements org.apache.hadoop.hbase.thrift.generated.Hbase.Iface CLEANUP_INTERVAL -static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String CLEANUP_INTERVAL +static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String CLEANUP_INTERVAL See Also: Constant Field Values @@ -797,7 +797,7 @@ implements org.apache.hadoop.hbase.thrift.generated.Hbase.Iface MAX_IDLETIME -static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String MAX_IDLETIME +static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String MAX_IDLETIME See Also: Constant Field Values @@ -818,7 +818,7 @@ implements org.apache.hadoop.hbase.thrift.generated.Hbase.Iface HBaseHandler -protectedHBaseHandler(org.apache.hadoop.conf.Configurationc, +protectedHBaseHandler(org.apache.hadoop.conf.Configurationc, UserProvideruserProvider) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException @@ -841,7 +841,7 @@ implements org.apache.hadoop.hbase.thrift.generated.Hbase.Iface getAllColumns -byte[][]getAllColumns(Tabletable) +byte[][]getAllColumns(Tabletable) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Returns a list of all the column families for a given Table. @@ -858,7 +858,7 @@ implements org.apache.hadoop.hbase.thrift.generated.Hbase.Iface getTable -publicTablegetTable(byte[]tableName) +publicTablegetTable(byte[]tableName) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException
[01/51] [partial] hbase-site git commit: Published site at .
Repository: hbase-site Updated Branches: refs/heads/asf-site d33b6ba3f -> aea328beb http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/src-html/org/apache/hadoop/hbase/Coprocessor.State.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/Coprocessor.State.html b/devapidocs/src-html/org/apache/hadoop/hbase/Coprocessor.State.html index de2285d..ba440ca 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/Coprocessor.State.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/Coprocessor.State.html @@ -28,60 +28,88 @@ 020package org.apache.hadoop.hbase; 021 022import java.io.IOException; -023import java.util.Optional; +023import java.util.Collections; 024 025import com.google.protobuf.Service; 026import org.apache.yetus.audience.InterfaceAudience; 027import org.apache.yetus.audience.InterfaceStability; 028 029/** -030 * Coprocessor interface. -031 */ -032@InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.COPROC) -033@InterfaceStability.Evolving -034public interface Coprocessor { -035 int VERSION = 1; -036 -037 /** Highest installation priority */ -038 int PRIORITY_HIGHEST = 0; -039 /** High (system) installation priority */ -040 int PRIORITY_SYSTEM = Integer.MAX_VALUE / 4; -041 /** Default installation priority for user coprocessors */ -042 int PRIORITY_USER = Integer.MAX_VALUE / 2; -043 /** Lowest installation priority */ -044 int PRIORITY_LOWEST = Integer.MAX_VALUE; -045 -046 /** -047 * Lifecycle state of a given coprocessor instance. -048 */ -049 enum State { -050UNINSTALLED, -051INSTALLED, -052STARTING, -053ACTIVE, -054STOPPING, -055STOPPED -056 } -057 -058 /** -059 * Called by the {@link CoprocessorEnvironment} during it's own startup to initialize the -060 * coprocessor. -061 */ -062 default void start(CoprocessorEnvironment env) throws IOException {} -063 -064 /** -065 * Called by the {@link CoprocessorEnvironment} during it's own shutdown to stop the -066 * coprocessor. -067 */ -068 default void stop(CoprocessorEnvironment env) throws IOException {} -069 -070 /** -071 * Coprocessor endpoints providing protobuf services should implement this interface. -072 */ -073 default OptionalService getService() { -074return Optional.empty(); -075 } -076} +030 * Base interface for the 4 coprocessors - MasterCoprocessor, RegionCoprocessor, +031 * RegionServerCoprocessor, and WALCoprocessor. +032 * Do NOT implement this interface directly. Unless an implementation implements one (or more) of +033 * the above mentioned 4 coprocessors, it'll fail to be loaded by any coprocessor host. +034 * +035 * Example: +036 * Building a coprocessor to observe Master operations. +037 * pre +038 * class MyMasterCoprocessor implements MasterCoprocessor { +039 * #64;Override +040 * public Optionallt;MasterObserver getMasterObserver() { +041 * return new MyMasterObserver(); +042 * } +043 * } +044 * +045 * class MyMasterObserver implements MasterObserver { +046 * +047 * } +048 * /pre +049 * +050 * Building a Service which can be loaded by both Master and RegionServer +051 * pre +052 * class MyCoprocessorService implements MasterCoprocessor, RegionServerCoprocessor { +053 * #64;Override +054 * public Optionallt;Service getServices() { +055 * return new ...; +056 * } +057 * } +058 * /pre +059 */ +060@InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.COPROC) +061@InterfaceStability.Evolving +062public interface Coprocessor { +063 int VERSION = 1; +064 +065 /** Highest installation priority */ +066 int PRIORITY_HIGHEST = 0; +067 /** High (system) installation priority */ +068 int PRIORITY_SYSTEM = Integer.MAX_VALUE / 4; +069 /** Default installation priority for user coprocessors */ +070 int PRIORITY_USER = Integer.MAX_VALUE / 2; +071 /** Lowest installation priority */ +072 int PRIORITY_LOWEST = Integer.MAX_VALUE; +073 +074 /** +075 * Lifecycle state of a given coprocessor instance. +076 */ +077 enum State { +078UNINSTALLED, +079INSTALLED, +080STARTING, +081ACTIVE, +082STOPPING, +083STOPPED +084 } +085 +086 /** +087 * Called by the {@link CoprocessorEnvironment} during it's own startup to initialize the +088 * coprocessor. +089 */ +090 default void start(CoprocessorEnvironment env) throws IOException {} +091 +092 /** +093 * Called by the {@link CoprocessorEnvironment} during it's own shutdown to stop the +094 * coprocessor. +095 */ +096 default void stop(CoprocessorEnvironment env) throws IOException {} +097 +098 /** +099 * Coprocessor endpoints providing protobuf services should implement this interface. +100 */ +101 default IterableService getServices() { +102return Collections.EMPTY_SET; +103 } +104}
[16/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowCell.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowCell.html index 26125e3..eb6a00d 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowCell.html @@ -28,3193 +28,3241 @@ 020 021import static org.apache.hadoop.hbase.HConstants.EMPTY_BYTE_ARRAY; 022import static org.apache.hadoop.hbase.Tag.TAG_LENGTH_SIZE; -023 -024import java.io.DataOutputStream; -025import java.io.IOException; -026import java.io.OutputStream; -027import java.math.BigDecimal; -028import java.nio.ByteBuffer; -029import java.util.ArrayList; -030import java.util.Arrays; -031import java.util.Iterator; -032import java.util.List; -033import java.util.Map.Entry; -034import java.util.NavigableMap; -035 -036import org.apache.hadoop.hbase.KeyValue.Type; -037import org.apache.yetus.audience.InterfaceAudience; -038import org.apache.yetus.audience.InterfaceAudience.Private; -039import org.apache.hadoop.hbase.io.HeapSize; -040import org.apache.hadoop.hbase.io.TagCompressionContext; -041import org.apache.hadoop.hbase.io.util.Dictionary; -042import org.apache.hadoop.hbase.io.util.StreamUtils; -043import org.apache.hadoop.hbase.util.ByteBufferUtils; -044import org.apache.hadoop.hbase.util.ByteRange; -045import org.apache.hadoop.hbase.util.Bytes; -046import org.apache.hadoop.hbase.util.ClassSize; -047 -048/** -049 * Utility methods helpful slinging {@link Cell} instances. -050 * Some methods below are for internal use only and are marked InterfaceAudience.Private at the -051 * method level. -052 */ -053@InterfaceAudience.Public -054public final class CellUtil { -055 -056 /** -057 * Private constructor to keep this class from being instantiated. -058 */ -059 private CellUtil(){} -060 -061 /*** ByteRange ***/ -062 -063 public static ByteRange fillRowRange(Cell cell, ByteRange range) { -064return range.set(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()); -065 } -066 -067 public static ByteRange fillFamilyRange(Cell cell, ByteRange range) { -068return range.set(cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength()); -069 } -070 -071 public static ByteRange fillQualifierRange(Cell cell, ByteRange range) { -072return range.set(cell.getQualifierArray(), cell.getQualifierOffset(), -073 cell.getQualifierLength()); -074 } -075 -076 public static ByteRange fillValueRange(Cell cell, ByteRange range) { -077return range.set(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength()); -078 } -079 -080 public static ByteRange fillTagRange(Cell cell, ByteRange range) { -081return range.set(cell.getTagsArray(), cell.getTagsOffset(), cell.getTagsLength()); -082 } -083 -084 /* get individual arrays for tests / -085 -086 public static byte[] cloneRow(Cell cell){ -087byte[] output = new byte[cell.getRowLength()]; -088copyRowTo(cell, output, 0); -089return output; -090 } -091 -092 public static byte[] cloneFamily(Cell cell){ -093byte[] output = new byte[cell.getFamilyLength()]; -094copyFamilyTo(cell, output, 0); -095return output; -096 } -097 -098 public static byte[] cloneQualifier(Cell cell){ -099byte[] output = new byte[cell.getQualifierLength()]; -100copyQualifierTo(cell, output, 0); -101return output; -102 } -103 -104 public static byte[] cloneValue(Cell cell){ -105byte[] output = new byte[cell.getValueLength()]; -106copyValueTo(cell, output, 0); -107return output; -108 } -109 -110 public static byte[] cloneTags(Cell cell) { -111byte[] output = new byte[cell.getTagsLength()]; -112copyTagTo(cell, output, 0); -113return output; -114 } -115 -116 /** -117 * Returns tag value in a new byte array. If server-side, use -118 * {@link Tag#getValueArray()} with appropriate {@link Tag#getValueOffset()} and -119 * {@link Tag#getValueLength()} instead to save on allocations. -120 * @param cell -121 * @return tag value in a new byte array. -122 */ -123 public static byte[] getTagArray(Cell cell){ -124byte[] output = new byte[cell.getTagsLength()]; -125copyTagTo(cell, output, 0); -126return output; -127 } -128 -129 -130 / copyTo **/ +023import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIMITER; +024import static org.apache.hadoop.hbase.KeyValue.getDelimiter; +025import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIM_ARRAY; +026 +027import java.io.DataOutputStream; +028import java.io.IOException; +029import
[14/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColCell.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColCell.html index 26125e3..eb6a00d 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColCell.html @@ -28,3193 +28,3241 @@ 020 021import static org.apache.hadoop.hbase.HConstants.EMPTY_BYTE_ARRAY; 022import static org.apache.hadoop.hbase.Tag.TAG_LENGTH_SIZE; -023 -024import java.io.DataOutputStream; -025import java.io.IOException; -026import java.io.OutputStream; -027import java.math.BigDecimal; -028import java.nio.ByteBuffer; -029import java.util.ArrayList; -030import java.util.Arrays; -031import java.util.Iterator; -032import java.util.List; -033import java.util.Map.Entry; -034import java.util.NavigableMap; -035 -036import org.apache.hadoop.hbase.KeyValue.Type; -037import org.apache.yetus.audience.InterfaceAudience; -038import org.apache.yetus.audience.InterfaceAudience.Private; -039import org.apache.hadoop.hbase.io.HeapSize; -040import org.apache.hadoop.hbase.io.TagCompressionContext; -041import org.apache.hadoop.hbase.io.util.Dictionary; -042import org.apache.hadoop.hbase.io.util.StreamUtils; -043import org.apache.hadoop.hbase.util.ByteBufferUtils; -044import org.apache.hadoop.hbase.util.ByteRange; -045import org.apache.hadoop.hbase.util.Bytes; -046import org.apache.hadoop.hbase.util.ClassSize; -047 -048/** -049 * Utility methods helpful slinging {@link Cell} instances. -050 * Some methods below are for internal use only and are marked InterfaceAudience.Private at the -051 * method level. -052 */ -053@InterfaceAudience.Public -054public final class CellUtil { -055 -056 /** -057 * Private constructor to keep this class from being instantiated. -058 */ -059 private CellUtil(){} -060 -061 /*** ByteRange ***/ -062 -063 public static ByteRange fillRowRange(Cell cell, ByteRange range) { -064return range.set(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()); -065 } -066 -067 public static ByteRange fillFamilyRange(Cell cell, ByteRange range) { -068return range.set(cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength()); -069 } -070 -071 public static ByteRange fillQualifierRange(Cell cell, ByteRange range) { -072return range.set(cell.getQualifierArray(), cell.getQualifierOffset(), -073 cell.getQualifierLength()); -074 } -075 -076 public static ByteRange fillValueRange(Cell cell, ByteRange range) { -077return range.set(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength()); -078 } -079 -080 public static ByteRange fillTagRange(Cell cell, ByteRange range) { -081return range.set(cell.getTagsArray(), cell.getTagsOffset(), cell.getTagsLength()); -082 } -083 -084 /* get individual arrays for tests / -085 -086 public static byte[] cloneRow(Cell cell){ -087byte[] output = new byte[cell.getRowLength()]; -088copyRowTo(cell, output, 0); -089return output; -090 } -091 -092 public static byte[] cloneFamily(Cell cell){ -093byte[] output = new byte[cell.getFamilyLength()]; -094copyFamilyTo(cell, output, 0); -095return output; -096 } -097 -098 public static byte[] cloneQualifier(Cell cell){ -099byte[] output = new byte[cell.getQualifierLength()]; -100copyQualifierTo(cell, output, 0); -101return output; -102 } -103 -104 public static byte[] cloneValue(Cell cell){ -105byte[] output = new byte[cell.getValueLength()]; -106copyValueTo(cell, output, 0); -107return output; -108 } -109 -110 public static byte[] cloneTags(Cell cell) { -111byte[] output = new byte[cell.getTagsLength()]; -112copyTagTo(cell, output, 0); -113return output; -114 } -115 -116 /** -117 * Returns tag value in a new byte array. If server-side, use -118 * {@link Tag#getValueArray()} with appropriate {@link Tag#getValueOffset()} and -119 * {@link Tag#getValueLength()} instead to save on allocations. -120 * @param cell -121 * @return tag value in a new byte array. -122 */ -123 public static byte[] getTagArray(Cell cell){ -124byte[] output = new byte[cell.getTagsLength()]; -125copyTagTo(cell, output, 0); -126return output; -127 } -128 -129 -130 / copyTo **/ +023import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIMITER; +024import static org.apache.hadoop.hbase.KeyValue.getDelimiter; +025import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIM_ARRAY; +026 +027import java.io.DataOutputStream; +028import java.io.IOException;
[35/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/org/apache/hadoop/hbase/KeyValue.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/KeyValue.html b/devapidocs/org/apache/hadoop/hbase/KeyValue.html index e8ee19b..386ed7c 100644 --- a/devapidocs/org/apache/hadoop/hbase/KeyValue.html +++ b/devapidocs/org/apache/hadoop/hbase/KeyValue.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":10,"i1":9,"i2":10,"i3":9,"i4":9,"i5":9,"i6":9,"i7":9,"i8":9,"i9":10,"i10":9,"i11":9,"i12":9,"i13":10,"i14":10,"i15":10,"i16":9,"i17":9,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":9,"i25":10,"i26":10,"i27":10,"i28":9,"i29":9,"i30":9,"i31":10,"i32":9,"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":42,"i53":10,"i54":10,"i55":10,"i56":10,"i57":10,"i58":10,"i59":9,"i60":41,"i61":42,"i62":9,"i63":10,"i64":9,"i65":9,"i66":9,"i67":41,"i68":9,"i69":10,"i70":10,"i71":10,"i72":10,"i73":10,"i74":10,"i75":10,"i76":10,"i77":9,"i78":10,"i79":9}; +var methods = {"i0":10,"i1":9,"i2":10,"i3":9,"i4":9,"i5":9,"i6":9,"i7":9,"i8":10,"i9":10,"i10":10,"i11":10,"i12":9,"i13":9,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":9,"i21":10,"i22":10,"i23":10,"i24":9,"i25":9,"i26":9,"i27":10,"i28":9,"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":9,"i57":9,"i58":41,"i59":10,"i60":10,"i61":10,"i62":10,"i63":10,"i64":10,"i65":10,"i66":10,"i67":9,"i68":10,"i69":9}; 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"; @@ -118,7 +118,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private -public class KeyValue +public class KeyValue 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 ExtendedCell An HBase Key/Value. This is the fundamental HBase Type. @@ -181,7 +181,7 @@ implements static class KeyValue.KVComparator Deprecated. -: Use CellComparator. +: Use CellComparator. Deprecated for hbase 2.0, remove for hbase 3.0. @@ -189,25 +189,11 @@ implements static class KeyValue.MetaComparator Deprecated. -: CellComparator.META_COMPARATOR to be used +: CellComparator.META_COMPARATOR to be used. Deprecated for hbase 2.0, remove for hbase 3.0. -static class -KeyValue.RawBytesComparator -Deprecated. -Not to be used for any comparsions - - - - -static class -KeyValue.RowOnlyComparator -Comparator that compares row component only of a KeyValue. - - - static interface KeyValue.SamePrefixComparatorT Avoids redundant comparisons for better performance. @@ -252,7 +238,7 @@ implements static KeyValue.KVComparator COMPARATOR Deprecated. -Use CellComparator.COMPARATOR instead +Use CellComparator.COMPARATOR instead. Deprecated for hbase 2.0, remove for hbase 3.0. @@ -306,7 +292,7 @@ implements static KeyValue.KVComparator META_COMPARATOR Deprecated. -Use CellComparator.META_COMPARATOR instead +Use CellComparator.META_COMPARATOR instead. Deprecated for hbase 2.0, remove for hbase 3.0. @@ -315,46 +301,40 @@ implements offset -static KeyValue.KVComparator -RAW_COMPARATOR -Deprecated. - - - static int ROW_KEY_OFFSET - + static int ROW_LENGTH_SIZE Size of the row length field in bytes - + static int ROW_OFFSET - + private long seqId - + static int TAGS_LENGTH_SIZE Size of the tags length field in bytes - + static int TIMESTAMP_SIZE Size of the timestamp field in bytes - + static int TIMESTAMP_TYPE_SIZE - + static int TYPE_SIZE Size of the key type field in bytes @@ -693,23 +673,16 @@ implements static KeyValue -cloneAndAddTags(Cellc, - http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListTagnewTags) -Create a new KeyValue by copying existing cell and adding new tags - - - -static KeyValue create(http://docs.oracle.com/javase/8/docs/api/java/io/DataInput.html?is-external=true; title="class or interface in java.io">DataInputin) - + static KeyValue create(intlength, http://docs.oracle.com/javase/8/docs/api/java/io/DataInput.html?is-external=true; title="class or interface in java.io">DataInputin) Create a KeyValue reading length from in - + private static byte[] createByteArray(byte[]row, introffset, @@ -731,7 +704,7 @@ implements Write KeyValue format into a byte array. - + private static byte[]
[15/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/aea328be/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColByteBufferCell.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColByteBufferCell.html b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColByteBufferCell.html index 26125e3..eb6a00d 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColByteBufferCell.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.FirstOnRowColByteBufferCell.html @@ -28,3193 +28,3241 @@ 020 021import static org.apache.hadoop.hbase.HConstants.EMPTY_BYTE_ARRAY; 022import static org.apache.hadoop.hbase.Tag.TAG_LENGTH_SIZE; -023 -024import java.io.DataOutputStream; -025import java.io.IOException; -026import java.io.OutputStream; -027import java.math.BigDecimal; -028import java.nio.ByteBuffer; -029import java.util.ArrayList; -030import java.util.Arrays; -031import java.util.Iterator; -032import java.util.List; -033import java.util.Map.Entry; -034import java.util.NavigableMap; -035 -036import org.apache.hadoop.hbase.KeyValue.Type; -037import org.apache.yetus.audience.InterfaceAudience; -038import org.apache.yetus.audience.InterfaceAudience.Private; -039import org.apache.hadoop.hbase.io.HeapSize; -040import org.apache.hadoop.hbase.io.TagCompressionContext; -041import org.apache.hadoop.hbase.io.util.Dictionary; -042import org.apache.hadoop.hbase.io.util.StreamUtils; -043import org.apache.hadoop.hbase.util.ByteBufferUtils; -044import org.apache.hadoop.hbase.util.ByteRange; -045import org.apache.hadoop.hbase.util.Bytes; -046import org.apache.hadoop.hbase.util.ClassSize; -047 -048/** -049 * Utility methods helpful slinging {@link Cell} instances. -050 * Some methods below are for internal use only and are marked InterfaceAudience.Private at the -051 * method level. -052 */ -053@InterfaceAudience.Public -054public final class CellUtil { -055 -056 /** -057 * Private constructor to keep this class from being instantiated. -058 */ -059 private CellUtil(){} -060 -061 /*** ByteRange ***/ -062 -063 public static ByteRange fillRowRange(Cell cell, ByteRange range) { -064return range.set(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()); -065 } -066 -067 public static ByteRange fillFamilyRange(Cell cell, ByteRange range) { -068return range.set(cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength()); -069 } -070 -071 public static ByteRange fillQualifierRange(Cell cell, ByteRange range) { -072return range.set(cell.getQualifierArray(), cell.getQualifierOffset(), -073 cell.getQualifierLength()); -074 } -075 -076 public static ByteRange fillValueRange(Cell cell, ByteRange range) { -077return range.set(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength()); -078 } -079 -080 public static ByteRange fillTagRange(Cell cell, ByteRange range) { -081return range.set(cell.getTagsArray(), cell.getTagsOffset(), cell.getTagsLength()); -082 } -083 -084 /* get individual arrays for tests / -085 -086 public static byte[] cloneRow(Cell cell){ -087byte[] output = new byte[cell.getRowLength()]; -088copyRowTo(cell, output, 0); -089return output; -090 } -091 -092 public static byte[] cloneFamily(Cell cell){ -093byte[] output = new byte[cell.getFamilyLength()]; -094copyFamilyTo(cell, output, 0); -095return output; -096 } -097 -098 public static byte[] cloneQualifier(Cell cell){ -099byte[] output = new byte[cell.getQualifierLength()]; -100copyQualifierTo(cell, output, 0); -101return output; -102 } -103 -104 public static byte[] cloneValue(Cell cell){ -105byte[] output = new byte[cell.getValueLength()]; -106copyValueTo(cell, output, 0); -107return output; -108 } -109 -110 public static byte[] cloneTags(Cell cell) { -111byte[] output = new byte[cell.getTagsLength()]; -112copyTagTo(cell, output, 0); -113return output; -114 } -115 -116 /** -117 * Returns tag value in a new byte array. If server-side, use -118 * {@link Tag#getValueArray()} with appropriate {@link Tag#getValueOffset()} and -119 * {@link Tag#getValueLength()} instead to save on allocations. -120 * @param cell -121 * @return tag value in a new byte array. -122 */ -123 public static byte[] getTagArray(Cell cell){ -124byte[] output = new byte[cell.getTagsLength()]; -125copyTagTo(cell, output, 0); -126return output; -127 } -128 -129 -130 / copyTo **/ +023import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIMITER; +024import static org.apache.hadoop.hbase.KeyValue.getDelimiter; +025import static org.apache.hadoop.hbase.KeyValue.COLUMN_FAMILY_DELIM_ARRAY; +026 +027import
hbase git commit: HBASE-18845 TestReplicationSmallTests fails after HBASE-14004
Repository: hbase Updated Branches: refs/heads/master afce850cf -> 239e68726 HBASE-18845 TestReplicationSmallTests fails after HBASE-14004 Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/239e6872 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/239e6872 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/239e6872 Branch: refs/heads/master Commit: 239e6872674ff122ecec2d8d6a557b269e6ae54b Parents: afce850 Author: zhangduoAuthored: Mon Sep 25 12:07:19 2017 +0800 Committer: zhangduo Committed: Fri Sep 29 14:32:26 2017 +0800 -- .../replication/TestReplicationSmallTests.java | 115 +-- .../hbase/replication/TestReplicationBase.java | 2 +- 2 files changed, 56 insertions(+), 61 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/239e6872/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationSmallTests.java -- diff --git a/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationSmallTests.java b/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationSmallTests.java index 6105a0d..28bf249 100644 --- a/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationSmallTests.java +++ b/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationSmallTests.java @@ -26,7 +26,6 @@ import static org.junit.Assert.fail; import java.io.IOException; import java.util.ArrayList; -import java.util.HashMap; import java.util.List; import java.util.NavigableMap; import java.util.TreeMap; @@ -39,13 +38,13 @@ import org.apache.hadoop.fs.Path; import org.apache.hadoop.hbase.Cell; import org.apache.hadoop.hbase.CellUtil; import org.apache.hadoop.hbase.HBaseTestingUtility; -import org.apache.hadoop.hbase.HColumnDescriptor; import org.apache.hadoop.hbase.HConstants; -import org.apache.hadoop.hbase.HTableDescriptor; import org.apache.hadoop.hbase.KeyValue; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.Waiter; import org.apache.hadoop.hbase.client.Admin; +import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor; +import org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder; import org.apache.hadoop.hbase.client.Connection; import org.apache.hadoop.hbase.client.ConnectionFactory; import org.apache.hadoop.hbase.client.Delete; @@ -57,10 +56,14 @@ import org.apache.hadoop.hbase.client.Result; import org.apache.hadoop.hbase.client.ResultScanner; import org.apache.hadoop.hbase.client.Scan; import org.apache.hadoop.hbase.client.Table; -import org.apache.hadoop.hbase.client.replication.ReplicationAdmin; +import org.apache.hadoop.hbase.client.TableDescriptor; +import org.apache.hadoop.hbase.client.TableDescriptorBuilder; +import org.apache.hadoop.hbase.client.replication.TableCFs; import org.apache.hadoop.hbase.mapreduce.replication.VerifyReplication; import org.apache.hadoop.hbase.regionserver.HRegion; +import org.apache.hadoop.hbase.regionserver.HRegionServer; import org.apache.hadoop.hbase.regionserver.MultiVersionConcurrencyControl; +import org.apache.hadoop.hbase.regionserver.wal.AbstractFSWAL; import org.apache.hadoop.hbase.replication.regionserver.Replication; import org.apache.hadoop.hbase.replication.regionserver.ReplicationSource; import org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface; @@ -73,8 +76,8 @@ import org.apache.hadoop.hbase.util.FSUtils; import org.apache.hadoop.hbase.util.JVMClusterUtil; import org.apache.hadoop.hbase.wal.AbstractFSWALProvider; import org.apache.hadoop.hbase.wal.WAL; -import org.apache.hadoop.hbase.wal.WALEdit; import org.apache.hadoop.hbase.wal.WALKey; +import org.apache.hadoop.hbase.wal.WALEdit; import org.apache.hadoop.mapreduce.Job; import org.junit.Before; import org.junit.Rule; @@ -162,7 +165,7 @@ public class TestReplicationSmallTests extends TestReplicationBase { htable1.put(put); Get get = new Get(row); -get.setMaxVersions(); +get.readAllVersions(); for (int i = 0; i < NB_RETRIES; i++) { if (i==NB_RETRIES-1) { fail("Waited too much time for put replication"); @@ -184,7 +187,7 @@ public class TestReplicationSmallTests extends TestReplicationBase { htable1.delete(d); get = new Get(row); -get.setMaxVersions(); +get.readAllVersions(); for (int i = 0; i < NB_RETRIES; i++) { if (i==NB_RETRIES-1) { fail("Waited too much time for put replication"); @@ -327,7 +330,7 @@ public class TestReplicationSmallTests extends TestReplicationBase { public void testDisableEnable() throws Exception { // Test disabling replication -
hbase git commit: HBASE-18845 TestReplicationSmallTests fails after HBASE-14004
Repository: hbase Updated Branches: refs/heads/branch-2 0658252ed -> 2e4c1b628 HBASE-18845 TestReplicationSmallTests fails after HBASE-14004 Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/2e4c1b62 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/2e4c1b62 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/2e4c1b62 Branch: refs/heads/branch-2 Commit: 2e4c1b62884026ba8fc2d743d33a7f9d9125393e Parents: 0658252 Author: zhangduoAuthored: Mon Sep 25 12:07:19 2017 +0800 Committer: zhangduo Committed: Fri Sep 29 14:32:33 2017 +0800 -- .../replication/TestReplicationSmallTests.java | 115 +-- .../hbase/replication/TestReplicationBase.java | 2 +- 2 files changed, 56 insertions(+), 61 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/2e4c1b62/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationSmallTests.java -- diff --git a/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationSmallTests.java b/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationSmallTests.java index 6105a0d..28bf249 100644 --- a/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationSmallTests.java +++ b/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationSmallTests.java @@ -26,7 +26,6 @@ import static org.junit.Assert.fail; import java.io.IOException; import java.util.ArrayList; -import java.util.HashMap; import java.util.List; import java.util.NavigableMap; import java.util.TreeMap; @@ -39,13 +38,13 @@ import org.apache.hadoop.fs.Path; import org.apache.hadoop.hbase.Cell; import org.apache.hadoop.hbase.CellUtil; import org.apache.hadoop.hbase.HBaseTestingUtility; -import org.apache.hadoop.hbase.HColumnDescriptor; import org.apache.hadoop.hbase.HConstants; -import org.apache.hadoop.hbase.HTableDescriptor; import org.apache.hadoop.hbase.KeyValue; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.Waiter; import org.apache.hadoop.hbase.client.Admin; +import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor; +import org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder; import org.apache.hadoop.hbase.client.Connection; import org.apache.hadoop.hbase.client.ConnectionFactory; import org.apache.hadoop.hbase.client.Delete; @@ -57,10 +56,14 @@ import org.apache.hadoop.hbase.client.Result; import org.apache.hadoop.hbase.client.ResultScanner; import org.apache.hadoop.hbase.client.Scan; import org.apache.hadoop.hbase.client.Table; -import org.apache.hadoop.hbase.client.replication.ReplicationAdmin; +import org.apache.hadoop.hbase.client.TableDescriptor; +import org.apache.hadoop.hbase.client.TableDescriptorBuilder; +import org.apache.hadoop.hbase.client.replication.TableCFs; import org.apache.hadoop.hbase.mapreduce.replication.VerifyReplication; import org.apache.hadoop.hbase.regionserver.HRegion; +import org.apache.hadoop.hbase.regionserver.HRegionServer; import org.apache.hadoop.hbase.regionserver.MultiVersionConcurrencyControl; +import org.apache.hadoop.hbase.regionserver.wal.AbstractFSWAL; import org.apache.hadoop.hbase.replication.regionserver.Replication; import org.apache.hadoop.hbase.replication.regionserver.ReplicationSource; import org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface; @@ -73,8 +76,8 @@ import org.apache.hadoop.hbase.util.FSUtils; import org.apache.hadoop.hbase.util.JVMClusterUtil; import org.apache.hadoop.hbase.wal.AbstractFSWALProvider; import org.apache.hadoop.hbase.wal.WAL; -import org.apache.hadoop.hbase.wal.WALEdit; import org.apache.hadoop.hbase.wal.WALKey; +import org.apache.hadoop.hbase.wal.WALEdit; import org.apache.hadoop.mapreduce.Job; import org.junit.Before; import org.junit.Rule; @@ -162,7 +165,7 @@ public class TestReplicationSmallTests extends TestReplicationBase { htable1.put(put); Get get = new Get(row); -get.setMaxVersions(); +get.readAllVersions(); for (int i = 0; i < NB_RETRIES; i++) { if (i==NB_RETRIES-1) { fail("Waited too much time for put replication"); @@ -184,7 +187,7 @@ public class TestReplicationSmallTests extends TestReplicationBase { htable1.delete(d); get = new Get(row); -get.setMaxVersions(); +get.readAllVersions(); for (int i = 0; i < NB_RETRIES; i++) { if (i==NB_RETRIES-1) { fail("Waited too much time for put replication"); @@ -327,7 +330,7 @@ public class TestReplicationSmallTests extends TestReplicationBase { public void testDisableEnable() throws Exception { // Test disabling replication -