phoenix git commit: PHOENIX-2696 Delete stale stats for a region if in later run no guidePosts found for that region(addendum)

2016-02-19 Thread ankit 
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.0 918990971 -> e27aa029f


PHOENIX-2696 Delete stale stats for a region if in later run no guidePosts 
found for that region(addendum)


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/e27aa029
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/e27aa029
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/e27aa029

Branch: refs/heads/4.x-HBase-1.0
Commit: e27aa029f51456e49fdc919c86eae8e82c6090f1
Parents: 9189909
Author: Ankit Singhal 
Authored: Fri Feb 19 23:43:14 2016 +0530
Committer: Ankit Singhal 
Committed: Fri Feb 19 23:43:14 2016 +0530

--
 .../apache/phoenix/schema/stats/DefaultStatisticsCollector.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/e27aa029/phoenix-core/src/main/java/org/apache/phoenix/schema/stats/DefaultStatisticsCollector.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/stats/DefaultStatisticsCollector.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/stats/DefaultStatisticsCollector.java
index ce6e7db..845f6d4 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/stats/DefaultStatisticsCollector.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/stats/DefaultStatisticsCollector.java
@@ -129,8 +129,8 @@ class DefaultStatisticsCollector implements 
StatisticsCollector {
 // This will not impact a stats collection of single column family 
during compaction as
 // guidePostsInfoWriterMap cannot be empty in this case.
 if (guidePostsInfoWriterMap.keySet().isEmpty()) {
-for (Store store : region.getStores()) {
-statsTable.deleteStats(region, this, new 
ImmutableBytesPtr(store.getFamily().getName()), mutations);
+for (byte[] fam : region.getStores().keySet()) {
+statsTable.deleteStats(region, this, new 
ImmutableBytesPtr(fam), mutations);
 }
 }
 for (ImmutableBytesPtr fam : guidePostsInfoWriterMap.keySet()) {

phoenix git commit: PHOENIX-2696 Delete stale stats for a region if in later run no guidePosts found for that region(addendum)

2016-02-19 Thread ankit 
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-0.98 eac2ba7e7 -> 072657081


PHOENIX-2696 Delete stale stats for a region if in later run no guidePosts 
found for that region(addendum)


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/07265708
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/07265708
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/07265708

Branch: refs/heads/4.x-HBase-0.98
Commit: 072657081bf8774a4bf9e0c9720cb65b13aabb2b
Parents: eac2ba7
Author: Ankit Singhal 
Authored: Fri Feb 19 23:38:50 2016 +0530
Committer: Ankit Singhal 
Committed: Fri Feb 19 23:38:50 2016 +0530

--
 .../apache/phoenix/schema/stats/DefaultStatisticsCollector.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/07265708/phoenix-core/src/main/java/org/apache/phoenix/schema/stats/DefaultStatisticsCollector.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/stats/DefaultStatisticsCollector.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/stats/DefaultStatisticsCollector.java
index c56c102..adce23c 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/stats/DefaultStatisticsCollector.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/stats/DefaultStatisticsCollector.java
@@ -128,8 +128,8 @@ public class DefaultStatisticsCollector implements 
StatisticsCollector {
 // This will not impact a stats collection of single column family 
during compaction as
 // guidePostsInfoWriterMap cannot be empty in this case.
 if (guidePostsInfoWriterMap.keySet().isEmpty()) {
-for (Store store : region.getStores()) {
-statsTable.deleteStats(region, this, new 
ImmutableBytesPtr(store.getFamily().getName()), mutations);
+for (byte[] fam : region.getStores().keySet()) {
+statsTable.deleteStats(region, this, new 
ImmutableBytesPtr(fam), mutations);
 }
 }
 for (ImmutableBytesPtr fam : guidePostsInfoWriterMap.keySet()) {