[3/3] phoenix git commit: PHOENIX-2722 support mysql offset clause

2016-04-08 Thread ankit 
PHOENIX-2722 support mysql offset clause


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

Branch: refs/heads/4.x-HBase-0.98
Commit: f65d0481d00e2fa70b03d97345377cb26d7fcb22
Parents: 4c588f4
Author: Ankit Singhal 
Authored: Fri Apr 8 16:06:50 2016 +0530
Committer: Ankit Singhal 
Committed: Fri Apr 8 16:06:50 2016 +0530

--
 .../apache/phoenix/end2end/AutoCommitIT.java|  14 +-
 .../apache/phoenix/end2end/CreateTableIT.java   |   2 +-
 .../apache/phoenix/end2end/DerivedTableIT.java  | 144 -
 .../org/apache/phoenix/end2end/HashJoinIT.java  | 161 ++
 .../phoenix/end2end/QueryWithOffsetIT.java  | 211 +++
 .../org/apache/phoenix/end2end/ReadOnlyIT.java  |  12 +-
 .../apache/phoenix/end2end/SortMergeJoinIT.java |  44 
 phoenix-core/src/main/antlr3/PhoenixSQL.g   |  16 +-
 .../apache/phoenix/compile/DeleteCompiler.java  |  13 +-
 .../apache/phoenix/compile/JoinCompiler.java|  10 +-
 .../phoenix/compile/ListJarsQueryPlan.java  |   5 +
 .../apache/phoenix/compile/OffsetCompiler.java  | 114 ++
 .../apache/phoenix/compile/OrderByCompiler.java |   3 +-
 .../apache/phoenix/compile/PostDDLCompiler.java |   3 +-
 .../apache/phoenix/compile/QueryCompiler.java   |  52 +++--
 .../org/apache/phoenix/compile/QueryPlan.java   |   2 +
 .../phoenix/compile/StatementNormalizer.java|   2 +-
 .../phoenix/compile/SubqueryRewriter.java   |  10 +-
 .../phoenix/compile/SubselectRewriter.java  |  15 +-
 .../apache/phoenix/compile/TraceQueryPlan.java  |   5 +
 .../apache/phoenix/compile/UpsertCompiler.java  |   2 +-
 .../coprocessor/BaseScannerRegionObserver.java  |   1 +
 .../phoenix/coprocessor/ScanRegionObserver.java |  95 -
 .../apache/phoenix/execute/AggregatePlan.java   |  43 ++--
 .../apache/phoenix/execute/BaseQueryPlan.java   |   9 +-
 .../phoenix/execute/ClientAggregatePlan.java|  19 +-
 .../phoenix/execute/ClientProcessingPlan.java   |  10 +-
 .../apache/phoenix/execute/ClientScanPlan.java  |  38 ++--
 .../phoenix/execute/DegenerateQueryPlan.java|   2 +-
 .../phoenix/execute/DelegateQueryPlan.java  |   4 +
 .../execute/LiteralResultIterationPlan.java |  13 +-
 .../org/apache/phoenix/execute/ScanPlan.java|  58 +++--
 .../phoenix/execute/SortMergeJoinPlan.java  |   5 +
 .../org/apache/phoenix/execute/UnionPlan.java   |  15 +-
 .../phoenix/iterate/BaseResultIterators.java|  14 +-
 .../apache/phoenix/iterate/ExplainTable.java|  16 +-
 .../phoenix/iterate/LimitingResultIterator.java |   2 +-
 .../iterate/MergeSortTopNResultIterator.java|  21 +-
 .../phoenix/iterate/OffsetResultIterator.java   |  62 ++
 .../OrderedAggregatingResultIterator.java   |   6 +-
 .../phoenix/iterate/OrderedResultIterator.java  |  58 +++--
 .../phoenix/iterate/ParallelIterators.java  |   4 +-
 .../apache/phoenix/iterate/SerialIterators.java |  19 +-
 .../phoenix/iterate/TableResultIterator.java|  22 +-
 .../apache/phoenix/jdbc/PhoenixStatement.java   |  18 +-
 .../org/apache/phoenix/join/HashJoinInfo.java   |   2 +-
 .../apache/phoenix/optimize/QueryOptimizer.java |   2 +-
 .../apache/phoenix/parse/DeleteStatement.java   |   6 +
 .../phoenix/parse/FilterableStatement.java  |   1 +
 .../org/apache/phoenix/parse/OffsetNode.java|  67 ++
 .../apache/phoenix/parse/ParseNodeFactory.java  |  55 +++--
 .../apache/phoenix/parse/ParseNodeRewriter.java |   2 +-
 .../apache/phoenix/parse/SelectStatement.java   |  35 ++-
 .../apache/phoenix/query/QueryConstants.java|   6 +
 .../java/org/apache/phoenix/util/QueryUtil.java |  30 ++-
 .../java/org/apache/phoenix/util/ScanUtil.java  |   4 +
 .../phoenix/execute/CorrelatePlanTest.java  |  39 +++-
 .../execute/LiteralResultIteratorPlanTest.java  | 192 +
 .../phoenix/execute/UnnestArrayPlanTest.java|   3 +-
 .../query/ParallelIteratorsSplitTest.java   |   5 +
 60 files changed, 1621 insertions(+), 222 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/f65d0481/phoenix-core/src/it/java/org/apache/phoenix/end2end/AutoCommitIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/AutoCommitIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/AutoCommitIT.java
index aa92c5e..469f2de 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/AutoCommitIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/AutoCommitIT.java
@@ -42,21 +42,21 @@ public class AutoCommitIT extends BaseHBaseManagedTimeIT {

[3/3] phoenix git commit: PHOENIX-2722 support mysql offset clause

2016-04-08 Thread ankit 
PHOENIX-2722 support mysql offset clause


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

Branch: refs/heads/master
Commit: 776eea9ce1c4828f959b9ef76dd244941972f6ec
Parents: 91800b7
Author: Ankit Singhal 
Authored: Fri Apr 8 15:04:17 2016 +0530
Committer: Ankit Singhal 
Committed: Fri Apr 8 15:04:17 2016 +0530

--
 .../apache/phoenix/end2end/AutoCommitIT.java|  14 +-
 .../apache/phoenix/end2end/CreateTableIT.java   |   2 +-
 .../apache/phoenix/end2end/DerivedTableIT.java  | 144 -
 .../org/apache/phoenix/end2end/HashJoinIT.java  | 161 ++
 .../phoenix/end2end/QueryWithOffsetIT.java  | 211 +++
 .../org/apache/phoenix/end2end/ReadOnlyIT.java  |  12 +-
 .../apache/phoenix/end2end/SortMergeJoinIT.java |  44 
 phoenix-core/src/main/antlr3/PhoenixSQL.g   |  16 +-
 .../apache/phoenix/compile/DeleteCompiler.java  |  13 +-
 .../apache/phoenix/compile/JoinCompiler.java|  10 +-
 .../phoenix/compile/ListJarsQueryPlan.java  |   5 +
 .../apache/phoenix/compile/OffsetCompiler.java  | 114 ++
 .../apache/phoenix/compile/OrderByCompiler.java |   3 +-
 .../apache/phoenix/compile/PostDDLCompiler.java |   3 +-
 .../apache/phoenix/compile/QueryCompiler.java   |  54 +++--
 .../org/apache/phoenix/compile/QueryPlan.java   |   2 +
 .../phoenix/compile/StatementNormalizer.java|   2 +-
 .../phoenix/compile/SubqueryRewriter.java   |  10 +-
 .../phoenix/compile/SubselectRewriter.java  |  17 +-
 .../apache/phoenix/compile/TraceQueryPlan.java  |   5 +
 .../apache/phoenix/compile/UpsertCompiler.java  |   2 +-
 .../coprocessor/BaseScannerRegionObserver.java  |   1 +
 .../phoenix/coprocessor/ScanRegionObserver.java |  95 -
 .../apache/phoenix/execute/AggregatePlan.java   |  43 ++--
 .../apache/phoenix/execute/BaseQueryPlan.java   |   9 +-
 .../phoenix/execute/ClientAggregatePlan.java|  19 +-
 .../phoenix/execute/ClientProcessingPlan.java   |  10 +-
 .../apache/phoenix/execute/ClientScanPlan.java  |  38 ++--
 .../phoenix/execute/DegenerateQueryPlan.java|   2 +-
 .../phoenix/execute/DelegateQueryPlan.java  |   4 +
 .../execute/LiteralResultIterationPlan.java |  13 +-
 .../org/apache/phoenix/execute/ScanPlan.java|  58 +++--
 .../phoenix/execute/SortMergeJoinPlan.java  |   5 +
 .../org/apache/phoenix/execute/UnionPlan.java   |  15 +-
 .../phoenix/iterate/BaseResultIterators.java|  14 +-
 .../apache/phoenix/iterate/ExplainTable.java|  16 +-
 .../phoenix/iterate/LimitingResultIterator.java |   2 +-
 .../iterate/MergeSortTopNResultIterator.java|  21 +-
 .../phoenix/iterate/OffsetResultIterator.java   |  62 ++
 .../OrderedAggregatingResultIterator.java   |   6 +-
 .../phoenix/iterate/OrderedResultIterator.java  |  58 +++--
 .../phoenix/iterate/ParallelIterators.java  |   4 +-
 .../apache/phoenix/iterate/SerialIterators.java |  19 +-
 .../phoenix/iterate/TableResultIterator.java|  22 +-
 .../apache/phoenix/jdbc/PhoenixStatement.java   |  18 +-
 .../org/apache/phoenix/join/HashJoinInfo.java   |   2 +-
 .../apache/phoenix/optimize/QueryOptimizer.java |   2 +-
 .../apache/phoenix/parse/DeleteStatement.java   |   6 +
 .../phoenix/parse/FilterableStatement.java  |   1 +
 .../org/apache/phoenix/parse/OffsetNode.java|  67 ++
 .../apache/phoenix/parse/ParseNodeFactory.java  |  55 +++--
 .../apache/phoenix/parse/ParseNodeRewriter.java |   2 +-
 .../apache/phoenix/parse/SelectStatement.java   |  35 ++-
 .../apache/phoenix/query/QueryConstants.java|   6 +
 .../java/org/apache/phoenix/util/QueryUtil.java |  30 ++-
 .../java/org/apache/phoenix/util/ScanUtil.java  |   4 +
 .../phoenix/execute/CorrelatePlanTest.java  |  39 +++-
 .../execute/LiteralResultIteratorPlanTest.java  | 192 +
 .../phoenix/execute/UnnestArrayPlanTest.java|   3 +-
 .../query/ParallelIteratorsSplitTest.java   |   5 +
 60 files changed, 1622 insertions(+), 225 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/776eea9c/phoenix-core/src/it/java/org/apache/phoenix/end2end/AutoCommitIT.java
--
diff --git 
a/phoenix-core/src/it/java/org/apache/phoenix/end2end/AutoCommitIT.java 
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/AutoCommitIT.java
index aa92c5e..469f2de 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/AutoCommitIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/AutoCommitIT.java
@@ -42,21 +42,21 @@ public class AutoCommitIT extends BaseHBaseManagedTimeIT {