[3/3] 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/3c72eef2 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/3c72eef2 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/3c72eef2 Branch: refs/heads/4.x-cdh5.14 Commit: 3c72eef250ffd6ea172d273121a400a944d02843 Parents: 0a06e59 Author: Pedro Boado Authored: Sat Mar 10 17:54:04 2018 + Committer: Pedro Boado Committed: Mon Jun 4 19:17:12 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/3c72eef2/phoenix-assembly/pom.xml -- diff --git a/phoenix-assembly/pom.xml b/phoenix-assembly/pom.xml index 7d98c25..e28d9f7 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 phoenix-assembly Phoenix Assembly http://git-wip-us.apache.org/repos/asf/phoenix/blob/3c72eef2/phoenix-client/pom.xml -- diff --git a/phoenix-client/pom.xml b/phoenix-client/pom.xml index fe5836b..9d0dee1 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 phoenix-client Phoenix Client http://git-wip-us.apache.org/repos/asf/phoenix/blob/3c72eef2/phoenix-core/pom.xml -- diff --git a/phoenix-core/pom.xml b/phoenix-core/pom.xml index 8b09c67..ab4c891 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 phoenix-core Phoenix Core http://git-wip-us.apache.org/repos/asf/phoenix/blob/3c72eef2/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/3c72eef2/phoenix-flume/pom.xml -- diff --git a/phoenix-flume/pom.xml b/phoenix-flume/pom.xml index e400589..d1e1363 100644 --- a/phoenix-flume/pom.xml +++ b/phoenix-flume/pom.xml @@ -26,7 +26,7 @@ org.apache.phoenix phoenix -4.14.0-cdh5.11.2 +4.14.0-cdh5.14.2
[3/3] 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/6fcdd950 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/6fcdd950 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/6fcdd950 Branch: refs/heads/4.x-cdh5.14 Commit: 6fcdd9509fa8035397089cd6aed3550be989e3c4 Parents: 01df0cb Author: Pedro BoadoAuthored: Sat Mar 10 17:54:04 2018 + Committer: Pedro Boado Committed: Sat Apr 28 19:15:25 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/6fcdd950/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/6fcdd950/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/6fcdd950/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/6fcdd950/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/6fcdd950/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 @@
[3/3] 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/b21867b8 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/b21867b8 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/b21867b8 Branch: refs/heads/4.x-cdh5.14 Commit: b21867b837b4487aa4f4d948d0acabf2d040d6d8 Parents: 8bba239 Author: Pedro BoadoAuthored: Sat Mar 10 17:54:04 2018 + Committer: Pedro Boado Committed: Sun Apr 22 11:14:08 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/b21867b8/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/b21867b8/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/b21867b8/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/b21867b8/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/b21867b8/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 @@
[3/3] 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/c9511069 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/c9511069 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/c9511069 Branch: refs/heads/4.x-cdh5.14 Commit: c95110694d1657149b752910b1373177660d3205 Parents: f3defc4 Author: Pedro BoadoAuthored: Sat Mar 10 17:54:04 2018 + Committer: Pedro Boado Committed: Fri Apr 6 22:17:30 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/c9511069/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/c9511069/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/c9511069/phoenix-core/pom.xml -- diff --git a/phoenix-core/pom.xml b/phoenix-core/pom.xml index b07cbbb..d215997 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/c9511069/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/c9511069/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 @@
[3/3] 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/69fdbe65 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/69fdbe65 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/69fdbe65 Branch: refs/heads/4.x-cdh5.14 Commit: 69fdbe6551bd35aec331af012f32d2f729e3e8ec Parents: ce3e586 Author: Pedro BoadoAuthored: Sat Mar 10 17:54:04 2018 + Committer: Pedro Boado Committed: Wed Apr 4 19:41:00 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/69fdbe65/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/69fdbe65/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/69fdbe65/phoenix-core/pom.xml -- diff --git a/phoenix-core/pom.xml b/phoenix-core/pom.xml index b07cbbb..d215997 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/69fdbe65/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/69fdbe65/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 @@