refs/heads/window_function - tajo

commit	d3ee50a95868a17cd69964adbd3f70149040ab6b	[log] [tgz]
author	Hyunsik Choi <hyunsik@apache.org>	Wed Jul 09 13:11:52 2014 +0900
committer	Hyunsik Choi <hyunsik@apache.org>	Wed Jul 09 13:13:45 2014 +0900
tree	c3972fc738871960d4bb95542263a50d059d068e
parent	a8bf9a36c7b9d7dd98802e102472b800ec05dcbd [diff]

TAJO-774: Implement logical plan part and physical executor for window function.

Closes #13

CHANGES[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/Aggregation.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/AlterTable.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/AlterTablespace.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/BetweenPredicate.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/BinaryOperator.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/CaseWhenPredicate.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/ColumnDefinition.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/ColumnReferenceExpr.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/CreateDatabase.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/CreateTable.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/DataTypeExpr.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/DateLiteral.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/DateValue.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/DropDatabase.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/DropTable.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/ExistsPredicate.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/Expr.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/FunctionExpr.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/GeneralSetFunctionExpr.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/Having.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/InPredicate.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/Insert.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/IsNullPredicate.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/Join.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/Limit.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/LiteralValue.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/NamedExpr.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/OpType.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/PatternMatchPredicate.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/Projection.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/QualifiedAsteriskExpr.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/Relation.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/RelationList.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/Selection.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/SetOperation.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/SignedExpr.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/Sort.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/TablePrimarySubQuery.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/TimeLiteral.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/TimeValue.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/TimestampLiteral.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/UnaryOperator.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/ValueListExpr.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/Window.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/WindowFunctionExpr.java[diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/WindowSpec.java[Added - diff]
tajo-algebra/src/main/java/org/apache/tajo/algebra/WindowSpecExpr.java[Deleted - diff]
tajo-catalog/tajo-catalog-common/src/main/java/org/apache/tajo/catalog/exception/NoSuchFunctionException.java[diff]
tajo-catalog/tajo-catalog-common/src/main/proto/CatalogProtos.proto[diff]
tajo-core/src/main/java/org/apache/tajo/engine/eval/AggregationFunctionCallEval.java[diff]
tajo-core/src/main/java/org/apache/tajo/engine/eval/AlgebraicUtil.java[diff]
tajo-core/src/main/java/org/apache/tajo/engine/eval/BasicEvalNodeVisitor.java[diff]
tajo-core/src/main/java/org/apache/tajo/engine/eval/BinaryEval.java[diff]
tajo-core/src/main/java/org/apache/tajo/engine/eval/EvalNodeVisitor2.java[diff]
tajo-core/src/main/java/org/apache/tajo/engine/eval/EvalType.java[diff]
tajo-core/src/main/java/org/apache/tajo/engine/eval/FunctionEval.java[diff]
tajo-core/src/main/java/org/apache/tajo/engine/eval/SimpleEvalNodeVisitor.java[diff]
tajo-core/src/main/java/org/apache/tajo/engine/eval/WindowFunctionEval.java[Added - diff]
tajo-core/src/main/java/org/apache/tajo/engine/function/WindowAggFunc.java[Added - diff]
tajo-core/src/main/java/org/apache/tajo/engine/function/window/Rank.java[Added - diff]
tajo-core/src/main/java/org/apache/tajo/engine/function/window/RowNumber.java[Added - diff]
tajo-core/src/main/java/org/apache/tajo/engine/parser/SQLAnalyzer.java[diff]
tajo-core/src/main/java/org/apache/tajo/engine/planner/AlgebraVisitor.java[diff]
tajo-core/src/main/java/org/apache/tajo/engine/planner/BaseAlgebraVisitor.java[diff]
tajo-core/src/main/java/org/apache/tajo/engine/planner/BasicLogicalPlanVisitor.java[diff]
tajo-core/src/main/java/org/apache/tajo/engine/planner/ExplainLogicalPlanVisitor.java[diff]
tajo-core/src/main/java/org/apache/tajo/engine/planner/ExprAnnotator.java[diff]
tajo-core/src/main/java/org/apache/tajo/engine/planner/ExprNormalizer.java[diff]
tajo-core/src/main/java/org/apache/tajo/engine/planner/LogicalPlan.java[diff]
tajo-core/src/main/java/org/apache/tajo/engine/planner/LogicalPlanPreprocessor.java[diff]
tajo-core/src/main/java/org/apache/tajo/engine/planner/LogicalPlanVisitor.java[diff]
tajo-core/src/main/java/org/apache/tajo/engine/planner/LogicalPlanner.java[diff]
tajo-core/src/main/java/org/apache/tajo/engine/planner/PhysicalPlannerImpl.java[diff]
tajo-core/src/main/java/org/apache/tajo/engine/planner/PlannerUtil.java[diff]
tajo-core/src/main/java/org/apache/tajo/engine/planner/SimpleAlgebraVisitor.java[diff]
tajo-core/src/main/java/org/apache/tajo/engine/planner/TypeDeterminant.java[Added - diff]
tajo-core/src/main/java/org/apache/tajo/engine/planner/global/GlobalPlanner.java[diff]
tajo-core/src/main/java/org/apache/tajo/engine/planner/logical/NodeType.java[diff]
tajo-core/src/main/java/org/apache/tajo/engine/planner/logical/WindowAggNode.java[Added - diff]
tajo-core/src/main/java/org/apache/tajo/engine/planner/logical/WindowSpec.java[Added - diff]
tajo-core/src/main/java/org/apache/tajo/engine/planner/physical/WindowAggExec.java[Added - diff]
tajo-core/src/main/java/org/apache/tajo/engine/planner/rewrite/FilterPushDownRule.java[diff]
tajo-core/src/main/java/org/apache/tajo/engine/planner/rewrite/ProjectionPushDownRule.java[diff]
tajo-core/src/main/java/org/apache/tajo/engine/utils/DataTypeUtil.java[Added - diff]
tajo-core/src/main/java/org/apache/tajo/master/GlobalEngine.java[diff]
tajo-core/src/test/java/org/apache/tajo/engine/parser/TestSQLAnalyzer.java[diff]
tajo-core/src/test/java/org/apache/tajo/engine/query/TestGroupByQuery.java[diff]
tajo-core/src/test/java/org/apache/tajo/engine/query/TestWindowQuery.java[Added - diff]
tajo-core/src/test/resources/queries/TestLogicalPlanner/window1.sql[Added - diff]
tajo-core/src/test/resources/queries/TestSQLAnalyzer/window1.sql[Renamed from tajo-core/tajo-core-backend/src/test/resources/queries/TestSQLAnalyzer/window1.sql - diff]
tajo-core/src/test/resources/queries/TestSQLAnalyzer/window2.sql[Renamed from tajo-core/tajo-core-backend/src/test/resources/queries/TestSQLAnalyzer/window2.sql - diff]
tajo-core/src/test/resources/queries/TestSQLAnalyzer/window3.sql[Renamed from tajo-core/tajo-core-backend/src/test/resources/queries/TestSQLAnalyzer/window3.sql - diff]
tajo-core/src/test/resources/queries/TestSQLAnalyzer/window4.sql[Renamed from tajo-core/tajo-core-backend/src/test/resources/queries/TestSQLAnalyzer/window4.sql - diff]
tajo-core/src/test/resources/queries/TestSQLAnalyzer/window5.sql[Renamed from tajo-core/tajo-core-backend/src/test/resources/queries/TestSQLAnalyzer/window5.sql - diff]
tajo-core/src/test/resources/queries/TestSQLAnalyzer/window6.sql[Renamed from tajo-core/tajo-core-backend/src/test/resources/queries/TestSQLAnalyzer/window6.sql - diff]
tajo-core/src/test/resources/queries/TestSQLAnalyzer/window7.sql[Renamed from tajo-core/tajo-core-backend/src/test/resources/queries/TestSQLAnalyzer/window7.sql - diff]
tajo-core/src/test/resources/queries/TestSQLAnalyzer/window8.sql[Renamed from tajo-core/tajo-core-backend/src/test/resources/queries/TestSQLAnalyzer/window8.sql - diff]
tajo-core/src/test/resources/queries/TestSQLAnalyzer/window9.sql[Renamed from tajo-core/tajo-core-backend/src/test/resources/queries/TestSQLAnalyzer/window9.sql - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/rowNumber1.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/rowNumber2.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/rowNumber3.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/testComplexOrderBy1.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/testWindow1.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/testWindow2.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/testWindow3.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/testWindow4.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/testWindow5.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/testWindow6.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/testWindow7.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/testWindowBeforeLimit.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/testWindowWithAggregation1.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/testWindowWithAggregation2.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/testWindowWithAggregation3.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/testWindowWithAggregation4.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/testWindowWithAggregation5.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/testWindowWithAggregation6.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/testWindowWithOrderBy1.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/testWindowWithOrderBy2.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/testWindowWithOrderBy3.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/testWindowWithOrderBy4.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/testWindowWithOrderBy5.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/testWindowWithSubQuery.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/testWindowWithSubQuery2.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/testWindowWithSubQuery3.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/testWindowWithSubQuery4.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/testWindowWithSubQuery5.sql[Added - diff]
tajo-core/src/test/resources/queries/TestWindowQuery/testWindowWithSubQuery6.sql[Added - diff]
tajo-core/src/test/resources/results/TestSQLAnalyzer/window1.result[Added - diff]
tajo-core/src/test/resources/results/TestSQLAnalyzer/window2.result[Added - diff]
tajo-core/src/test/resources/results/TestSQLAnalyzer/window3.result[Added - diff]
tajo-core/src/test/resources/results/TestSQLAnalyzer/window4.result[Added - diff]
tajo-core/src/test/resources/results/TestSQLAnalyzer/window5.result[Added - diff]
tajo-core/src/test/resources/results/TestSQLAnalyzer/window6.result[Added - diff]
tajo-core/src/test/resources/results/TestSQLAnalyzer/window7.result[Added - diff]
tajo-core/src/test/resources/results/TestSQLAnalyzer/window8.result[Added - diff]
tajo-core/src/test/resources/results/TestSQLAnalyzer/window9.result[Added - diff]
tajo-core/src/test/resources/results/TestSelectQuery/testSumFloatOverflow.result[diff]
tajo-core/src/test/resources/results/TestSelectQuery/testSumIntOverflow.result[diff]
tajo-core/src/test/resources/results/TestWindowQuery/rowNumber1.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/rowNumber2.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/rowNumber3.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/testComplexOrderBy1.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/testWindow1.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/testWindow2.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/testWindow3.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/testWindow4.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/testWindow5.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/testWindow6.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/testWindow7.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/testWindowBeforeLimit.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/testWindowWithAggregation1.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/testWindowWithAggregation2.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/testWindowWithAggregation3.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/testWindowWithAggregation4.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/testWindowWithAggregation5.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/testWindowWithAggregation6.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/testWindowWithOrderBy1.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/testWindowWithOrderBy2.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/testWindowWithOrderBy3.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/testWindowWithOrderBy4.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/testWindowWithOrderBy5.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/testWindowWithSubQuery.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/testWindowWithSubQuery2.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/testWindowWithSubQuery3.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/testWindowWithSubQuery4.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/testWindowWithSubQuery5.result[Added - diff]
tajo-core/src/test/resources/results/TestWindowQuery/testWindowWithSubQuery6.result[Added - diff]
tajo-core/tajo-core-backend/src/test/resources/results/TestSQLAnalyzer/window1.result[Deleted - diff]
tajo-core/tajo-core-backend/src/test/resources/results/TestSQLAnalyzer/window2.result[Deleted - diff]
tajo-core/tajo-core-backend/src/test/resources/results/TestSQLAnalyzer/window3.result[Deleted - diff]
tajo-core/tajo-core-backend/src/test/resources/results/TestSQLAnalyzer/window4.result[Deleted - diff]
tajo-core/tajo-core-backend/src/test/resources/results/TestSQLAnalyzer/window5.result[Deleted - diff]
tajo-core/tajo-core-backend/src/test/resources/results/TestSQLAnalyzer/window6.result[Deleted - diff]
tajo-core/tajo-core-backend/src/test/resources/results/TestSQLAnalyzer/window7.result[Deleted - diff]
tajo-core/tajo-core-backend/src/test/resources/results/TestSQLAnalyzer/window8.result[Deleted - diff]
tajo-core/tajo-core-backend/src/test/resources/results/TestSQLAnalyzer/window9.result[Deleted - diff]
tajo-storage/src/main/java/org/apache/tajo/storage/BinarySerializerDeserializer.java[diff]

178 files changed