Repository: phoenix Updated Branches: refs/heads/4.0 6fc5cbe16 -> 1cbe68f16
Phoenix-1296 Scan entire region when tenant-specific table is analyzed Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/1cbe68f1 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/1cbe68f1 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/1cbe68f1 Branch: refs/heads/4.0 Commit: 1cbe68f16a7ea0b0184a75fba6723b34e786d816 Parents: 6fc5cbe Author: Ramkrishna <ramkrishna.s.vasude...@intel.com> Authored: Sun Sep 28 16:46:47 2014 +0530 Committer: Ramkrishna <ramkrishna.s.vasude...@intel.com> Committed: Sun Sep 28 16:46:47 2014 +0530 ---------------------------------------------------------------------- .../phoenix/coprocessor/UngroupedAggregateRegionObserver.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/1cbe68f1/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/UngroupedAggregateRegionObserver.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/UngroupedAggregateRegionObserver.java b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/UngroupedAggregateRegionObserver.java index dae7465..508ae52 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/UngroupedAggregateRegionObserver.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/UngroupedAggregateRegionObserver.java @@ -38,6 +38,7 @@ import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.hbase.Cell; import org.apache.hadoop.hbase.CoprocessorEnvironment; +import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.HRegionInfo; import org.apache.hadoop.hbase.KeyValue; import org.apache.hadoop.hbase.TableName; @@ -153,6 +154,11 @@ public class UngroupedAggregateRegionObserver extends BaseScannerRegionObserver{ if(scan.getAttribute(BaseScannerRegionObserver.ANALYZE_TABLE) != null && statsTable != null) { stats = new StatisticsCollector(statsTable, c.getEnvironment().getConfiguration()); isAnalyze = true; + // We are setting the start row and stop row such that it covers the entire region. As part + // of Phonenix-1263 we are storing the guideposts against the physical table rather than + // individual tenant specific tables. + scan.setStartRow(HConstants.EMPTY_START_ROW); + scan.setStopRow(HConstants.EMPTY_END_ROW); } if (ScanUtil.isLocalIndex(scan)) { /*
