[5/5] phoenix git commit: Changes for CDH 5.14.x
Changes for CDH 5.14.x Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/af16a3d7 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/af16a3d7 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/af16a3d7 Branch: refs/heads/4.x-cdh5.14 Commit: af16a3d77fca3c768ba80121e599b88d833de73f Parents: 84106f4 Author: Pedro BoadoAuthored: Sat Mar 10 17:54:04 2018 + Committer: Pedro Boado Committed: Sun May 13 10:53:31 2018 +0100 -- phoenix-assembly/pom.xml| 2 +- phoenix-client/pom.xml | 2 +- phoenix-core/pom.xml| 2 +- .../hadoop/hbase/ipc/PhoenixRpcScheduler.java | 34 ++-- phoenix-flume/pom.xml | 2 +- phoenix-hive/pom.xml| 2 +- phoenix-kafka/pom.xml | 2 +- phoenix-load-balancer/pom.xml | 2 +- phoenix-parcel/pom.xml | 2 +- phoenix-pherf/pom.xml | 2 +- phoenix-pig/pom.xml | 2 +- phoenix-queryserver-client/pom.xml | 2 +- phoenix-queryserver/pom.xml | 2 +- phoenix-server/pom.xml | 2 +- phoenix-spark/pom.xml | 2 +- phoenix-tracing-webapp/pom.xml | 2 +- pom.xml | 4 +-- 17 files changed, 49 insertions(+), 19 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/af16a3d7/phoenix-assembly/pom.xml -- diff --git a/phoenix-assembly/pom.xml b/phoenix-assembly/pom.xml index 7d98c25..c013cf0 100644 --- a/phoenix-assembly/pom.xml +++ b/phoenix-assembly/pom.xml @@ -27,7 +27,7 @@ org.apache.phoenix phoenix -4.14.0-cdh5.11.2 +4.14.0-cdh5.14.2-SNAPSHOT phoenix-assembly Phoenix Assembly http://git-wip-us.apache.org/repos/asf/phoenix/blob/af16a3d7/phoenix-client/pom.xml -- diff --git a/phoenix-client/pom.xml b/phoenix-client/pom.xml index fef18c2..6de0f65 100644 --- a/phoenix-client/pom.xml +++ b/phoenix-client/pom.xml @@ -27,7 +27,7 @@ org.apache.phoenix phoenix -4.14.0-cdh5.11.2 +4.14.0-cdh5.14.2-SNAPSHOT phoenix-client Phoenix Client http://git-wip-us.apache.org/repos/asf/phoenix/blob/af16a3d7/phoenix-core/pom.xml -- diff --git a/phoenix-core/pom.xml b/phoenix-core/pom.xml index 60c04d4..d17facf 100644 --- a/phoenix-core/pom.xml +++ b/phoenix-core/pom.xml @@ -4,7 +4,7 @@ org.apache.phoenix phoenix -4.14.0-cdh5.11.2 +4.14.0-cdh5.14.2-SNAPSHOT phoenix-core Phoenix Core http://git-wip-us.apache.org/repos/asf/phoenix/blob/af16a3d7/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java -- diff --git a/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java b/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java index 4fdddf5..d1f05f8 100644 --- a/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java +++ b/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java @@ -124,6 +124,36 @@ public class PhoenixRpcScheduler extends RpcScheduler { public void setMetadataExecutorForTesting(RpcExecutor executor) { this.metadataCallExecutor = executor; } - - + +@Override +public int getReadQueueLength() { +return delegate.getReadQueueLength(); +} + +@Override +public int getWriteQueueLength() { +return delegate.getWriteQueueLength(); +} + +@Override +public int getScanQueueLength() { +return delegate.getScanQueueLength(); +} + +@Override +public int getActiveReadRpcHandlerCount() { +return delegate.getActiveReadRpcHandlerCount(); +} + +@Override +public int getActiveWriteRpcHandlerCount() { +return delegate.getActiveWriteRpcHandlerCount(); +} + +@Override +public int getActiveScanRpcHandlerCount() { +return delegate.getActiveScanRpcHandlerCount(); +} + + } http://git-wip-us.apache.org/repos/asf/phoenix/blob/af16a3d7/phoenix-flume/pom.xml -- diff --git a/phoenix-flume/pom.xml b/phoenix-flume/pom.xml index e400589..e0532cb 100644 --- a/phoenix-flume/pom.xml +++ b/phoenix-flume/pom.xml @@ -26,7 +26,7 @@ org.apache.phoenix
[5/5] phoenix git commit: Changes for CDH 5.14.x
Changes for CDH 5.14.x Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/2b22c298 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/2b22c298 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/2b22c298 Branch: refs/heads/4.x-cdh5.14 Commit: 2b22c2986111b7e11edf7d89cd7707b0412772ee Parents: 6b5ff31 Author: Pedro BoadoAuthored: Sat Mar 10 17:54:04 2018 + Committer: Pedro Boado Committed: Tue May 1 22:52:28 2018 +0100 -- phoenix-assembly/pom.xml| 2 +- phoenix-client/pom.xml | 2 +- phoenix-core/pom.xml| 2 +- .../hadoop/hbase/ipc/PhoenixRpcScheduler.java | 34 ++-- phoenix-flume/pom.xml | 2 +- phoenix-hive/pom.xml| 2 +- phoenix-kafka/pom.xml | 2 +- phoenix-load-balancer/pom.xml | 2 +- phoenix-parcel/pom.xml | 2 +- phoenix-pherf/pom.xml | 2 +- phoenix-pig/pom.xml | 2 +- phoenix-queryserver-client/pom.xml | 2 +- phoenix-queryserver/pom.xml | 2 +- phoenix-server/pom.xml | 2 +- phoenix-spark/pom.xml | 2 +- phoenix-tracing-webapp/pom.xml | 2 +- pom.xml | 4 +-- 17 files changed, 49 insertions(+), 19 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/2b22c298/phoenix-assembly/pom.xml -- diff --git a/phoenix-assembly/pom.xml b/phoenix-assembly/pom.xml index 55a9a6e..c013cf0 100644 --- a/phoenix-assembly/pom.xml +++ b/phoenix-assembly/pom.xml @@ -27,7 +27,7 @@ org.apache.phoenix phoenix -4.14.0-cdh5.11.2-SNAPSHOT +4.14.0-cdh5.14.2-SNAPSHOT phoenix-assembly Phoenix Assembly http://git-wip-us.apache.org/repos/asf/phoenix/blob/2b22c298/phoenix-client/pom.xml -- diff --git a/phoenix-client/pom.xml b/phoenix-client/pom.xml index 2454de6..6de0f65 100644 --- a/phoenix-client/pom.xml +++ b/phoenix-client/pom.xml @@ -27,7 +27,7 @@ org.apache.phoenix phoenix -4.14.0-cdh5.11.2-SNAPSHOT +4.14.0-cdh5.14.2-SNAPSHOT phoenix-client Phoenix Client http://git-wip-us.apache.org/repos/asf/phoenix/blob/2b22c298/phoenix-core/pom.xml -- diff --git a/phoenix-core/pom.xml b/phoenix-core/pom.xml index e1f8e2a..d17facf 100644 --- a/phoenix-core/pom.xml +++ b/phoenix-core/pom.xml @@ -4,7 +4,7 @@ org.apache.phoenix phoenix -4.14.0-cdh5.11.2-SNAPSHOT +4.14.0-cdh5.14.2-SNAPSHOT phoenix-core Phoenix Core http://git-wip-us.apache.org/repos/asf/phoenix/blob/2b22c298/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java -- diff --git a/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java b/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java index 4fdddf5..d1f05f8 100644 --- a/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java +++ b/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java @@ -124,6 +124,36 @@ public class PhoenixRpcScheduler extends RpcScheduler { public void setMetadataExecutorForTesting(RpcExecutor executor) { this.metadataCallExecutor = executor; } - - + +@Override +public int getReadQueueLength() { +return delegate.getReadQueueLength(); +} + +@Override +public int getWriteQueueLength() { +return delegate.getWriteQueueLength(); +} + +@Override +public int getScanQueueLength() { +return delegate.getScanQueueLength(); +} + +@Override +public int getActiveReadRpcHandlerCount() { +return delegate.getActiveReadRpcHandlerCount(); +} + +@Override +public int getActiveWriteRpcHandlerCount() { +return delegate.getActiveWriteRpcHandlerCount(); +} + +@Override +public int getActiveScanRpcHandlerCount() { +return delegate.getActiveScanRpcHandlerCount(); +} + + } http://git-wip-us.apache.org/repos/asf/phoenix/blob/2b22c298/phoenix-flume/pom.xml -- diff --git a/phoenix-flume/pom.xml b/phoenix-flume/pom.xml index d61a9aa..e0532cb 100644 --- a/phoenix-flume/pom.xml +++ b/phoenix-flume/pom.xml @@ -26,7 +26,7 @@
[5/5] phoenix git commit: Changes for CDH 5.14.x
Changes for CDH 5.14.x Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/0f85035c Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/0f85035c Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/0f85035c Branch: refs/heads/4.x-cdh5.14 Commit: 0f85035c0a585c97d90b0d2e9f181dbdce2c65c5 Parents: 352903b Author: Pedro BoadoAuthored: Sat Mar 10 17:54:04 2018 + Committer: Pedro Boado Committed: Fri Apr 27 19:54:54 2018 +0100 -- phoenix-assembly/pom.xml| 2 +- phoenix-client/pom.xml | 2 +- phoenix-core/pom.xml| 2 +- .../hadoop/hbase/ipc/PhoenixRpcScheduler.java | 34 ++-- phoenix-flume/pom.xml | 2 +- phoenix-hive/pom.xml| 2 +- phoenix-kafka/pom.xml | 2 +- phoenix-load-balancer/pom.xml | 2 +- phoenix-parcel/pom.xml | 2 +- phoenix-pherf/pom.xml | 2 +- phoenix-pig/pom.xml | 2 +- phoenix-queryserver-client/pom.xml | 2 +- phoenix-queryserver/pom.xml | 2 +- phoenix-server/pom.xml | 2 +- phoenix-spark/pom.xml | 2 +- phoenix-tracing-webapp/pom.xml | 2 +- pom.xml | 4 +-- 17 files changed, 49 insertions(+), 19 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/0f85035c/phoenix-assembly/pom.xml -- diff --git a/phoenix-assembly/pom.xml b/phoenix-assembly/pom.xml index 55a9a6e..c013cf0 100644 --- a/phoenix-assembly/pom.xml +++ b/phoenix-assembly/pom.xml @@ -27,7 +27,7 @@ org.apache.phoenix phoenix -4.14.0-cdh5.11.2-SNAPSHOT +4.14.0-cdh5.14.2-SNAPSHOT phoenix-assembly Phoenix Assembly http://git-wip-us.apache.org/repos/asf/phoenix/blob/0f85035c/phoenix-client/pom.xml -- diff --git a/phoenix-client/pom.xml b/phoenix-client/pom.xml index 2454de6..6de0f65 100644 --- a/phoenix-client/pom.xml +++ b/phoenix-client/pom.xml @@ -27,7 +27,7 @@ org.apache.phoenix phoenix -4.14.0-cdh5.11.2-SNAPSHOT +4.14.0-cdh5.14.2-SNAPSHOT phoenix-client Phoenix Client http://git-wip-us.apache.org/repos/asf/phoenix/blob/0f85035c/phoenix-core/pom.xml -- diff --git a/phoenix-core/pom.xml b/phoenix-core/pom.xml index e1f8e2a..d17facf 100644 --- a/phoenix-core/pom.xml +++ b/phoenix-core/pom.xml @@ -4,7 +4,7 @@ org.apache.phoenix phoenix -4.14.0-cdh5.11.2-SNAPSHOT +4.14.0-cdh5.14.2-SNAPSHOT phoenix-core Phoenix Core http://git-wip-us.apache.org/repos/asf/phoenix/blob/0f85035c/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java -- diff --git a/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java b/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java index 4fdddf5..d1f05f8 100644 --- a/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java +++ b/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java @@ -124,6 +124,36 @@ public class PhoenixRpcScheduler extends RpcScheduler { public void setMetadataExecutorForTesting(RpcExecutor executor) { this.metadataCallExecutor = executor; } - - + +@Override +public int getReadQueueLength() { +return delegate.getReadQueueLength(); +} + +@Override +public int getWriteQueueLength() { +return delegate.getWriteQueueLength(); +} + +@Override +public int getScanQueueLength() { +return delegate.getScanQueueLength(); +} + +@Override +public int getActiveReadRpcHandlerCount() { +return delegate.getActiveReadRpcHandlerCount(); +} + +@Override +public int getActiveWriteRpcHandlerCount() { +return delegate.getActiveWriteRpcHandlerCount(); +} + +@Override +public int getActiveScanRpcHandlerCount() { +return delegate.getActiveScanRpcHandlerCount(); +} + + } http://git-wip-us.apache.org/repos/asf/phoenix/blob/0f85035c/phoenix-flume/pom.xml -- diff --git a/phoenix-flume/pom.xml b/phoenix-flume/pom.xml index d61a9aa..e0532cb 100644 --- a/phoenix-flume/pom.xml +++ b/phoenix-flume/pom.xml @@ -26,7 +26,7 @@
[5/5] phoenix git commit: Changes for CDH 5.14.x
Changes for CDH 5.14.x Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/213a0016 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/213a0016 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/213a0016 Branch: refs/heads/4.x-cdh5.14 Commit: 213a001612e110457c0c52f597ca342d1e799c61 Parents: 9948036 Author: Pedro BoadoAuthored: Sat Mar 10 17:54:04 2018 + Committer: Pedro Boado Committed: Thu Apr 19 22:03:14 2018 +0100 -- phoenix-assembly/pom.xml| 2 +- phoenix-client/pom.xml | 2 +- phoenix-core/pom.xml| 2 +- .../hadoop/hbase/ipc/PhoenixRpcScheduler.java | 34 ++-- phoenix-flume/pom.xml | 2 +- phoenix-hive/pom.xml| 2 +- phoenix-kafka/pom.xml | 2 +- phoenix-load-balancer/pom.xml | 2 +- phoenix-parcel/pom.xml | 2 +- phoenix-pherf/pom.xml | 2 +- phoenix-pig/pom.xml | 2 +- phoenix-queryserver-client/pom.xml | 2 +- phoenix-queryserver/pom.xml | 2 +- phoenix-server/pom.xml | 2 +- phoenix-spark/pom.xml | 2 +- phoenix-tracing-webapp/pom.xml | 2 +- pom.xml | 4 +-- 17 files changed, 49 insertions(+), 19 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/213a0016/phoenix-assembly/pom.xml -- diff --git a/phoenix-assembly/pom.xml b/phoenix-assembly/pom.xml index 55a9a6e..862ec23 100644 --- a/phoenix-assembly/pom.xml +++ b/phoenix-assembly/pom.xml @@ -27,7 +27,7 @@ org.apache.phoenix phoenix -4.14.0-cdh5.11.2-SNAPSHOT +4.14.0-cdh5.14.0-SNAPSHOT phoenix-assembly Phoenix Assembly http://git-wip-us.apache.org/repos/asf/phoenix/blob/213a0016/phoenix-client/pom.xml -- diff --git a/phoenix-client/pom.xml b/phoenix-client/pom.xml index 2454de6..470dd05 100644 --- a/phoenix-client/pom.xml +++ b/phoenix-client/pom.xml @@ -27,7 +27,7 @@ org.apache.phoenix phoenix -4.14.0-cdh5.11.2-SNAPSHOT +4.14.0-cdh5.14.0-SNAPSHOT phoenix-client Phoenix Client http://git-wip-us.apache.org/repos/asf/phoenix/blob/213a0016/phoenix-core/pom.xml -- diff --git a/phoenix-core/pom.xml b/phoenix-core/pom.xml index e1f8e2a..f8afaa1 100644 --- a/phoenix-core/pom.xml +++ b/phoenix-core/pom.xml @@ -4,7 +4,7 @@ org.apache.phoenix phoenix -4.14.0-cdh5.11.2-SNAPSHOT +4.14.0-cdh5.14.0-SNAPSHOT phoenix-core Phoenix Core http://git-wip-us.apache.org/repos/asf/phoenix/blob/213a0016/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java -- diff --git a/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java b/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java index 4fdddf5..d1f05f8 100644 --- a/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java +++ b/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java @@ -124,6 +124,36 @@ public class PhoenixRpcScheduler extends RpcScheduler { public void setMetadataExecutorForTesting(RpcExecutor executor) { this.metadataCallExecutor = executor; } - - + +@Override +public int getReadQueueLength() { +return delegate.getReadQueueLength(); +} + +@Override +public int getWriteQueueLength() { +return delegate.getWriteQueueLength(); +} + +@Override +public int getScanQueueLength() { +return delegate.getScanQueueLength(); +} + +@Override +public int getActiveReadRpcHandlerCount() { +return delegate.getActiveReadRpcHandlerCount(); +} + +@Override +public int getActiveWriteRpcHandlerCount() { +return delegate.getActiveWriteRpcHandlerCount(); +} + +@Override +public int getActiveScanRpcHandlerCount() { +return delegate.getActiveScanRpcHandlerCount(); +} + + } http://git-wip-us.apache.org/repos/asf/phoenix/blob/213a0016/phoenix-flume/pom.xml -- diff --git a/phoenix-flume/pom.xml b/phoenix-flume/pom.xml index d61a9aa..4b8a0ff 100644 --- a/phoenix-flume/pom.xml +++ b/phoenix-flume/pom.xml @@ -26,7 +26,7 @@
[5/5] phoenix git commit: Changes for CDH 5.14.x
Changes for CDH 5.14.x Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/a80821d0 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/a80821d0 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/a80821d0 Branch: refs/heads/4.x-cdh5.14 Commit: a80821d060317b827da631ddfef10d1bde89353d Parents: 881d7aa Author: Pedro BoadoAuthored: Sat Mar 10 17:54:04 2018 + Committer: Pedro Boado Committed: Fri Mar 23 21:36:34 2018 + -- phoenix-assembly/pom.xml| 2 +- phoenix-client/pom.xml | 2 +- phoenix-core/pom.xml| 2 +- .../hadoop/hbase/ipc/PhoenixRpcScheduler.java | 34 ++-- phoenix-flume/pom.xml | 2 +- phoenix-hive/pom.xml| 2 +- phoenix-kafka/pom.xml | 2 +- phoenix-load-balancer/pom.xml | 2 +- phoenix-parcel/pom.xml | 2 +- phoenix-pherf/pom.xml | 2 +- phoenix-pig/pom.xml | 2 +- phoenix-queryserver-client/pom.xml | 2 +- phoenix-queryserver/pom.xml | 2 +- phoenix-server/pom.xml | 2 +- phoenix-spark/pom.xml | 2 +- phoenix-tracing-webapp/pom.xml | 2 +- pom.xml | 4 +-- 17 files changed, 49 insertions(+), 19 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/a80821d0/phoenix-assembly/pom.xml -- diff --git a/phoenix-assembly/pom.xml b/phoenix-assembly/pom.xml index 55a9a6e..862ec23 100644 --- a/phoenix-assembly/pom.xml +++ b/phoenix-assembly/pom.xml @@ -27,7 +27,7 @@ org.apache.phoenix phoenix -4.14.0-cdh5.11.2-SNAPSHOT +4.14.0-cdh5.14.0-SNAPSHOT phoenix-assembly Phoenix Assembly http://git-wip-us.apache.org/repos/asf/phoenix/blob/a80821d0/phoenix-client/pom.xml -- diff --git a/phoenix-client/pom.xml b/phoenix-client/pom.xml index 2454de6..470dd05 100644 --- a/phoenix-client/pom.xml +++ b/phoenix-client/pom.xml @@ -27,7 +27,7 @@ org.apache.phoenix phoenix -4.14.0-cdh5.11.2-SNAPSHOT +4.14.0-cdh5.14.0-SNAPSHOT phoenix-client Phoenix Client http://git-wip-us.apache.org/repos/asf/phoenix/blob/a80821d0/phoenix-core/pom.xml -- diff --git a/phoenix-core/pom.xml b/phoenix-core/pom.xml index 2cb4c81..d24dbea 100644 --- a/phoenix-core/pom.xml +++ b/phoenix-core/pom.xml @@ -4,7 +4,7 @@ org.apache.phoenix phoenix -4.14.0-cdh5.11.2-SNAPSHOT +4.14.0-cdh5.14.0-SNAPSHOT phoenix-core Phoenix Core http://git-wip-us.apache.org/repos/asf/phoenix/blob/a80821d0/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java -- diff --git a/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java b/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java index 4fdddf5..d1f05f8 100644 --- a/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java +++ b/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java @@ -124,6 +124,36 @@ public class PhoenixRpcScheduler extends RpcScheduler { public void setMetadataExecutorForTesting(RpcExecutor executor) { this.metadataCallExecutor = executor; } - - + +@Override +public int getReadQueueLength() { +return delegate.getReadQueueLength(); +} + +@Override +public int getWriteQueueLength() { +return delegate.getWriteQueueLength(); +} + +@Override +public int getScanQueueLength() { +return delegate.getScanQueueLength(); +} + +@Override +public int getActiveReadRpcHandlerCount() { +return delegate.getActiveReadRpcHandlerCount(); +} + +@Override +public int getActiveWriteRpcHandlerCount() { +return delegate.getActiveWriteRpcHandlerCount(); +} + +@Override +public int getActiveScanRpcHandlerCount() { +return delegate.getActiveScanRpcHandlerCount(); +} + + } http://git-wip-us.apache.org/repos/asf/phoenix/blob/a80821d0/phoenix-flume/pom.xml -- diff --git a/phoenix-flume/pom.xml b/phoenix-flume/pom.xml index 0883e5e..a7aef39 100644 --- a/phoenix-flume/pom.xml +++ b/phoenix-flume/pom.xml @@ -26,7 +26,7 @@