You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tajo.apache.org by hy...@apache.org on 2014/04/18 11:20:13 UTC
[51/51] [partial] git commit: TAJO-752: Escalate sub modules in
tajo-core into the top-level modules. (hyunsik)
TAJO-752: Escalate sub modules in tajo-core into the top-level modules. (hyunsik)
Project: http://git-wip-us.apache.org/repos/asf/tajo/repo
Commit: http://git-wip-us.apache.org/repos/asf/tajo/commit/6594ac1c
Tree: http://git-wip-us.apache.org/repos/asf/tajo/tree/6594ac1c
Diff: http://git-wip-us.apache.org/repos/asf/tajo/diff/6594ac1c
Branch: refs/heads/master
Commit: 6594ac1c00192537b0796d0404e0ddf9d6e37111
Parents: 795077d
Author: Hyunsik Choi <hy...@apache.org>
Authored: Fri Apr 18 18:19:00 2014 +0900
Committer: Hyunsik Choi <hy...@apache.org>
Committed: Fri Apr 18 18:19:00 2014 +0900
----------------------------------------------------------------------
CHANGES.txt | 3 +
pom.xml | 1 +
tajo-client/pom.xml | 2 +-
.../java/org/apache/tajo/client/TajoDump.java | 13 +-
.../java/org/apache/tajo/util/FileUtil.java | 5 +
tajo-core/benchmark/simple/groupby1.sql | 6 +
tajo-core/benchmark/simple/groupby2.sql | 6 +
tajo-core/benchmark/simple/selection1.sql | 5 +
tajo-core/benchmark/simple/selection2.sql | 5 +
tajo-core/benchmark/simple/selection3.sql | 7 +
tajo-core/benchmark/tpch/customer.schema | 9 +
tajo-core/benchmark/tpch/lineitem.schema | 19 +
tajo-core/benchmark/tpch/nation.schema | 6 +
tajo-core/benchmark/tpch/orders.schema | 11 +
tajo-core/benchmark/tpch/part.schema | 11 +
tajo-core/benchmark/tpch/partsupp.schema | 8 +
tajo-core/benchmark/tpch/q1.sql | 21 +
tajo-core/benchmark/tpch/q10.sql | 31 +
tajo-core/benchmark/tpch/q11.sql | 27 +
tajo-core/benchmark/tpch/q12.sql | 24 +
tajo-core/benchmark/tpch/q13.sql | 18 +
tajo-core/benchmark/tpch/q14.sql | 13 +
tajo-core/benchmark/tpch/q15.sql | 32 +
tajo-core/benchmark/tpch/q16.sql | 30 +
tajo-core/benchmark/tpch/q17.sql | 17 +
tajo-core/benchmark/tpch/q18.sql | 33 +
tajo-core/benchmark/tpch/q19.sql | 35 +
tajo-core/benchmark/tpch/q2.sql | 38 +
tajo-core/benchmark/tpch/q20.sql | 36 +
tajo-core/benchmark/tpch/q21.sql | 39 +
tajo-core/benchmark/tpch/q22.sql | 36 +
tajo-core/benchmark/tpch/q3.sql | 22 +
tajo-core/benchmark/tpch/q4.sql | 21 +
tajo-core/benchmark/tpch/q5.sql | 24 +
tajo-core/benchmark/tpch/q6.sql | 10 +
tajo-core/benchmark/tpch/q7.sql | 38 +
tajo-core/benchmark/tpch/q8.sql | 37 +
tajo-core/benchmark/tpch/q9.sql | 31 +
tajo-core/benchmark/tpch/region.schema | 5 +
tajo-core/benchmark/tpch/supplier.schema | 9 +
tajo-core/pom.xml | 649 +-
.../apache/tajo/engine/parser/HiveQLLexer.g4 | 390 +
.../apache/tajo/engine/parser/HiveQLParser.g4 | 2067 ++++
.../org/apache/tajo/engine/parser/SQLLexer.g4 | 479 +
.../org/apache/tajo/engine/parser/SQLParser.g4 | 1398 +++
tajo-core/src/main/java/log4j.properties | 30 +
.../org/apache/tajo/benchmark/BenchmarkSet.java | 120 +
.../java/org/apache/tajo/benchmark/Driver.java | 46 +
.../org/apache/tajo/benchmark/SimpleQuery.java | 29 +
.../java/org/apache/tajo/benchmark/TPCH.java | 200 +
.../eval/AggregationFunctionCallEval.java | 92 +
.../tajo/engine/eval/AlgebraicException.java | 41 +
.../apache/tajo/engine/eval/AlgebraicUtil.java | 398 +
.../tajo/engine/eval/BasicEvalNodeVisitor.java | 341 +
.../tajo/engine/eval/BetweenPredicateEval.java | 219 +
.../org/apache/tajo/engine/eval/BinaryEval.java | 205 +
.../apache/tajo/engine/eval/CaseWhenEval.java | 208 +
.../org/apache/tajo/engine/eval/CastEval.java | 87 +
.../org/apache/tajo/engine/eval/ConstEval.java | 99 +
.../org/apache/tajo/engine/eval/EvalNode.java | 118 +
.../tajo/engine/eval/EvalNodeVisitor.java | 24 +
.../tajo/engine/eval/EvalNodeVisitor2.java | 71 +
.../tajo/engine/eval/EvalTreeFactory.java | 32 +
.../apache/tajo/engine/eval/EvalTreeUtil.java | 350 +
.../org/apache/tajo/engine/eval/EvalType.java | 83 +
.../org/apache/tajo/engine/eval/FieldEval.java | 114 +
.../apache/tajo/engine/eval/FunctionEval.java | 144 +
.../tajo/engine/eval/GeneralFunctionEval.java | 81 +
.../org/apache/tajo/engine/eval/InEval.java | 86 +
.../tajo/engine/eval/InvalidCastException.java | 36 +
.../tajo/engine/eval/InvalidEvalException.java | 36 +
.../org/apache/tajo/engine/eval/IsNullEval.java | 84 +
.../tajo/engine/eval/LikePredicateEval.java | 50 +
.../org/apache/tajo/engine/eval/NotEval.java | 92 +
.../tajo/engine/eval/PartialBinaryExpr.java | 70 +
.../engine/eval/PatternMatchPredicateEval.java | 82 +
.../tajo/engine/eval/RegexPredicateEval.java | 53 +
.../tajo/engine/eval/RowConstantEval.java | 79 +
.../org/apache/tajo/engine/eval/SignedEval.java | 99 +
.../engine/eval/SimilarToPredicateEval.java | 43 +
.../exception/AmbiguousFieldException.java | 30 +
.../exception/IllegalQueryStatusException.java | 38 +
.../engine/exception/InvalidQueryException.java | 35 +
.../engine/exception/NoSuchColumnException.java | 25 +
.../exception/RangeOverflowException.java | 28 +
.../tajo/engine/exception/VerifyException.java | 27 +
.../tajo/engine/function/AggFunction.java | 58 +
.../tajo/engine/function/FunctionContext.java | 22 +
.../tajo/engine/function/GeneralFunction.java | 56 +
.../engine/function/annotation/Description.java | 50 +
.../function/annotation/ParamOptionTypes.java | 29 +
.../engine/function/annotation/ParamTypes.java | 30 +
.../tajo/engine/function/builtin/AvgDouble.java | 97 +
.../tajo/engine/function/builtin/AvgFloat.java | 46 +
.../tajo/engine/function/builtin/AvgInt.java | 47 +
.../tajo/engine/function/builtin/AvgLong.java | 96 +
.../tajo/engine/function/builtin/Coalesce.java | 44 +
.../engine/function/builtin/CoalesceDouble.java | 43 +
.../engine/function/builtin/CoalesceLong.java | 44 +
.../engine/function/builtin/CoalesceString.java | 44 +
.../tajo/engine/function/builtin/CountRows.java | 84 +
.../engine/function/builtin/CountValue.java | 55 +
.../function/builtin/CountValueDistinct.java | 90 +
.../tajo/engine/function/builtin/Date.java | 62 +
.../tajo/engine/function/builtin/MaxDouble.java | 78 +
.../tajo/engine/function/builtin/MaxFloat.java | 76 +
.../tajo/engine/function/builtin/MaxInt.java | 77 +
.../tajo/engine/function/builtin/MaxLong.java | 77 +
.../tajo/engine/function/builtin/MaxString.java | 81 +
.../tajo/engine/function/builtin/MinDouble.java | 77 +
.../tajo/engine/function/builtin/MinFloat.java | 78 +
.../tajo/engine/function/builtin/MinInt.java | 77 +
.../tajo/engine/function/builtin/MinLong.java | 78 +
.../tajo/engine/function/builtin/MinString.java | 82 +
.../tajo/engine/function/builtin/RandomInt.java | 57 +
.../tajo/engine/function/builtin/Sleep.java | 52 +
.../tajo/engine/function/builtin/SumDouble.java | 82 +
.../function/builtin/SumDoubleDistinct.java | 98 +
.../tajo/engine/function/builtin/SumFloat.java | 80 +
.../function/builtin/SumFloatDistinct.java | 98 +
.../tajo/engine/function/builtin/SumInt.java | 82 +
.../engine/function/builtin/SumIntDistinct.java | 98 +
.../tajo/engine/function/builtin/SumLong.java | 82 +
.../function/builtin/SumLongDistinct.java | 98 +
.../tajo/engine/function/builtin/Today.java | 46 +
.../function/datetime/DatePartFromDate.java | 194 +
.../function/datetime/DatePartFromTime.java | 140 +
.../datetime/DatePartFromTimestamp.java | 259 +
.../datetime/DateTimePartFromUnixTimeStamp.java | 141 +
.../function/datetime/ToCharTimestamp.java | 79 +
.../engine/function/datetime/ToTimestamp.java | 55 +
.../function/geoip/GeoIPCountryInet4.java | 55 +
.../engine/function/geoip/GeoIPCountryText.java | 56 +
.../function/geoip/GeoIPInCountryInet4.java | 61 +
.../function/geoip/GeoIPInCountryText.java | 60 +
.../tajo/engine/function/math/AbsDouble.java | 61 +
.../tajo/engine/function/math/AbsFloat.java | 61 +
.../tajo/engine/function/math/AbsInt.java | 61 +
.../tajo/engine/function/math/AbsLong.java | 60 +
.../apache/tajo/engine/function/math/Acos.java | 61 +
.../apache/tajo/engine/function/math/Asin.java | 60 +
.../apache/tajo/engine/function/math/Atan.java | 60 +
.../apache/tajo/engine/function/math/Atan2.java | 62 +
.../apache/tajo/engine/function/math/Cbrt.java | 61 +
.../apache/tajo/engine/function/math/Ceil.java | 63 +
.../apache/tajo/engine/function/math/Cos.java | 60 +
.../tajo/engine/function/math/Degrees.java | 61 +
.../apache/tajo/engine/function/math/Div.java | 77 +
.../apache/tajo/engine/function/math/Exp.java | 61 +
.../apache/tajo/engine/function/math/Floor.java | 61 +
.../apache/tajo/engine/function/math/Mod.java | 77 +
.../apache/tajo/engine/function/math/Pi.java | 51 +
.../apache/tajo/engine/function/math/Pow.java | 78 +
.../tajo/engine/function/math/Radians.java | 62 +
.../apache/tajo/engine/function/math/Round.java | 71 +
.../apache/tajo/engine/function/math/Sign.java | 64 +
.../apache/tajo/engine/function/math/Sin.java | 60 +
.../apache/tajo/engine/function/math/Sqrt.java | 62 +
.../apache/tajo/engine/function/math/Tan.java | 60 +
.../tajo/engine/function/string/Ascii.java | 67 +
.../tajo/engine/function/string/BTrim.java | 77 +
.../tajo/engine/function/string/BitLength.java | 58 +
.../tajo/engine/function/string/CharLength.java | 59 +
.../apache/tajo/engine/function/string/Chr.java | 65 +
.../tajo/engine/function/string/Concat.java | 73 +
.../tajo/engine/function/string/Concat_ws.java | 78 +
.../tajo/engine/function/string/Decode.java | 91 +
.../tajo/engine/function/string/Digest.java | 87 +
.../tajo/engine/function/string/Encode.java | 93 +
.../tajo/engine/function/string/FindInSet.java | 116 +
.../function/string/HexStringConverter.java | 65 +
.../tajo/engine/function/string/InitCap.java | 60 +
.../tajo/engine/function/string/LTrim.java | 77 +
.../tajo/engine/function/string/Left.java | 84 +
.../tajo/engine/function/string/Length.java | 61 +
.../tajo/engine/function/string/Locate.java | 106 +
.../tajo/engine/function/string/Lower.java | 58 +
.../tajo/engine/function/string/Lpad.java | 90 +
.../apache/tajo/engine/function/string/Md5.java | 65 +
.../engine/function/string/OctetLength.java | 61 +
.../tajo/engine/function/string/QuoteIdent.java | 67 +
.../tajo/engine/function/string/RTrim.java | 76 +
.../engine/function/string/RegexpReplace.java | 115 +
.../tajo/engine/function/string/Repeat.java | 72 +
.../tajo/engine/function/string/Reverse.java | 58 +
.../tajo/engine/function/string/Right.java | 85 +
.../tajo/engine/function/string/Rpad.java | 90 +
.../tajo/engine/function/string/SplitPart.java | 73 +
.../tajo/engine/function/string/StrPos.java | 73 +
.../tajo/engine/function/string/StrPosb.java | 120 +
.../tajo/engine/function/string/Substr.java | 94 +
.../tajo/engine/function/string/ToBin.java | 65 +
.../tajo/engine/function/string/ToHex.java | 76 +
.../tajo/engine/function/string/Upper.java | 58 +
.../apache/tajo/engine/json/CoreGsonHelper.java | 90 +
.../tajo/engine/json/EvalNodeAdapter.java | 50 +
.../tajo/engine/json/LogicalNodeAdapter.java | 50 +
.../tajo/engine/parser/HiveQLAnalyzer.java | 1550 +++
.../apache/tajo/engine/parser/SQLAnalyzer.java | 1516 +++
.../tajo/engine/parser/SQLErrorListener.java | 38 +
.../tajo/engine/parser/SQLErrorStrategy.java | 66 +
.../tajo/engine/parser/SQLParseError.java | 107 +
.../tajo/engine/parser/SQLSyntaxError.java | 51 +
.../tajo/engine/planner/AlgebraVisitor.java | 110 +
.../engine/planner/AlterTablespaceNode.java | 103 +
.../tajo/engine/planner/BaseAlgebraVisitor.java | 739 ++
.../engine/planner/BasicLogicalPlanVisitor.java | 319 +
.../planner/BroadcastJoinPlanVisitor.java | 86 +
.../planner/ExplainLogicalPlanVisitor.java | 236 +
.../tajo/engine/planner/ExprAnnotator.java | 631 +
.../apache/tajo/engine/planner/ExprFinder.java | 74 +
.../tajo/engine/planner/ExprNormalizer.java | 257 +
.../tajo/engine/planner/ExprsVerifier.java | 216 +
.../tajo/engine/planner/GroupElement.java | 64 +
.../tajo/engine/planner/LogicalOptimizer.java | 280 +
.../apache/tajo/engine/planner/LogicalPlan.java | 782 ++
.../engine/planner/LogicalPlanPreprocessor.java | 442 +
.../engine/planner/LogicalPlanVerifier.java | 249 +
.../tajo/engine/planner/LogicalPlanVisitor.java | 91 +
.../tajo/engine/planner/LogicalPlanner.java | 1579 +++
.../tajo/engine/planner/NamedExprsManager.java | 369 +
.../tajo/engine/planner/PhysicalPlanner.java | 36 +
.../engine/planner/PhysicalPlannerImpl.java | 1057 ++
.../planner/PhysicalPlanningException.java | 31 +
.../apache/tajo/engine/planner/PlanString.java | 119 +
.../apache/tajo/engine/planner/PlannerUtil.java | 762 ++
.../tajo/engine/planner/PlanningException.java | 29 +
.../engine/planner/PreLogicalPlanVerifier.java | 274 +
.../apache/tajo/engine/planner/Projector.java | 51 +
.../engine/planner/RangePartitionAlgorithm.java | 187 +
.../engine/planner/SimpleAlgebraVisitor.java | 215 +
.../org/apache/tajo/engine/planner/Target.java | 129 +
.../engine/planner/UniformRangePartition.java | 451 +
.../tajo/engine/planner/VerificationState.java | 44 +
.../tajo/engine/planner/enforce/Enforcer.java | 262 +
.../tajo/engine/planner/global/DataChannel.java | 200 +
.../engine/planner/global/ExecutionBlock.java | 127 +
.../planner/global/ExecutionBlockCursor.java | 93 +
.../engine/planner/global/GlobalPlanner.java | 1187 ++
.../tajo/engine/planner/global/MasterPlan.java | 268 +
.../engine/planner/graph/DirectedGraph.java | 64 +
.../planner/graph/DirectedGraphCursor.java | 65 +
.../planner/graph/DirectedGraphVisitor.java | 25 +
.../apache/tajo/engine/planner/graph/Graph.java | 45 +
.../planner/graph/SimpleDirectedGraph.java | 270 +
.../planner/graph/SimpleUndirectedGraph.java | 102 +
.../engine/planner/graph/UndirectedGraph.java | 30 +
.../engine/planner/logical/AlterTableNode.java | 134 +
.../tajo/engine/planner/logical/BinaryNode.java | 77 +
.../planner/logical/CreateDatabaseNode.java | 87 +
.../engine/planner/logical/CreateTableNode.java | 145 +
.../planner/logical/DropDatabaseNode.java | 85 +
.../engine/planner/logical/DropTableNode.java | 95 +
.../engine/planner/logical/EvalExprNode.java | 83 +
.../tajo/engine/planner/logical/ExceptNode.java | 45 +
.../engine/planner/logical/GroupbyNode.java | 198 +
.../tajo/engine/planner/logical/HavingNode.java | 67 +
.../engine/planner/logical/IndexScanNode.java | 122 +
.../tajo/engine/planner/logical/InsertNode.java | 182 +
.../engine/planner/logical/IntersectNode.java | 44 +
.../tajo/engine/planner/logical/JoinNode.java | 165 +
.../tajo/engine/planner/logical/LimitNode.java | 65 +
.../engine/planner/logical/LogicalNode.java | 128 +
.../planner/logical/LogicalNodeVisitor.java | 27 +
.../engine/planner/logical/LogicalRootNode.java | 41 +
.../tajo/engine/planner/logical/NodeType.java | 66 +
.../logical/PartitionedTableScanNode.java | 155 +
.../planner/logical/PersistentStoreNode.java | 90 +
.../engine/planner/logical/Projectable.java | 73 +
.../engine/planner/logical/ProjectionNode.java | 114 +
.../engine/planner/logical/RelationNode.java | 49 +
.../tajo/engine/planner/logical/ScanNode.java | 234 +
.../engine/planner/logical/SelectionNode.java | 69 +
.../planner/logical/ShuffleFileWriteNode.java | 104 +
.../tajo/engine/planner/logical/SortNode.java | 94 +
.../engine/planner/logical/StoreTableNode.java | 100 +
.../planner/logical/TableSubQueryNode.java | 181 +
.../tajo/engine/planner/logical/UnaryNode.java | 69 +
.../tajo/engine/planner/logical/UnionNode.java | 37 +
.../tajo/engine/planner/logical/join/Edge.java | 50 +
.../planner/logical/join/FoundJoinOrder.java | 47 +
.../join/GreedyHeuristicJoinOrderAlgorithm.java | 262 +
.../engine/planner/logical/join/JoinEdge.java | 76 +
.../engine/planner/logical/join/JoinGraph.java | 115 +
.../logical/join/JoinOrderAlgorithm.java | 46 +
.../planner/physical/AggregationExec.java | 69 +
.../engine/planner/physical/BNLJoinExec.java | 223 +
.../planner/physical/BSTIndexScanExec.java | 143 +
.../physical/BasicPhysicalExecutorVisitor.java | 265 +
.../planner/physical/BinaryPhysicalExec.java | 109 +
.../planner/physical/ColPartitionStoreExec.java | 100 +
.../engine/planner/physical/EvalExprExec.java | 66 +
.../planner/physical/ExternalSortExec.java | 782 ++
.../planner/physical/HashAggregateExec.java | 115 +
.../HashBasedColPartitionStoreExec.java | 132 +
.../planner/physical/HashFullOuterJoinExec.java | 252 +
.../engine/planner/physical/HashJoinExec.java | 202 +
.../planner/physical/HashLeftAntiJoinExec.java | 109 +
.../planner/physical/HashLeftOuterJoinExec.java | 212 +
.../planner/physical/HashLeftSemiJoinExec.java | 107 +
.../planner/physical/HashPartitioner.java | 49 +
.../physical/HashShuffleFileWriteExec.java | 160 +
.../engine/planner/physical/HavingExec.java | 50 +
.../planner/physical/JoinTupleComparator.java | 87 +
.../tajo/engine/planner/physical/LimitExec.java | 55 +
.../engine/planner/physical/MemSortExec.java | 89 +
.../physical/MergeFullOuterJoinExec.java | 335 +
.../engine/planner/physical/MergeJoinExec.java | 193 +
.../engine/planner/physical/NLJoinExec.java | 104 +
.../planner/physical/NLLeftOuterJoinExec.java | 122 +
.../physical/PartitionMergeScanExec.java | 143 +
.../engine/planner/physical/Partitioner.java | 45 +
.../engine/planner/physical/PhysicalExec.java | 79 +
.../physical/PhysicalExecutorVisitor.java | 107 +
.../planner/physical/PhysicalPlanUtil.java | 39 +
.../physical/PhysicalPlanningException.java | 31 +
.../engine/planner/physical/ProjectionExec.java | 69 +
.../physical/RangeShuffleFileWriteExec.java | 131 +
.../physical/RightOuterMergeJoinExec.java | 346 +
.../engine/planner/physical/SelectionExec.java | 49 +
.../engine/planner/physical/SeqScanExec.java | 316 +
.../planner/physical/SortAggregateExec.java | 125 +
.../SortBasedColPartitionStoreExec.java | 149 +
.../tajo/engine/planner/physical/SortExec.java | 51 +
.../engine/planner/physical/StoreTableExec.java | 102 +
.../engine/planner/physical/TunnelExec.java | 42 +
.../planner/physical/UnaryPhysicalExec.java | 96 +
.../tajo/engine/planner/physical/UnionExec.java | 62 +
.../rewrite/BasicQueryRewriteEngine.java | 70 +
.../planner/rewrite/FilterPushDownRule.java | 323 +
.../rewrite/PartitionedTableRewriter.java | 373 +
.../planner/rewrite/ProjectionPushDownRule.java | 966 ++
.../planner/rewrite/QueryRewriteEngine.java | 32 +
.../engine/planner/rewrite/RewriteRule.java | 56 +
.../apache/tajo/engine/query/QueryContext.java | 191 +
.../tajo/engine/query/QueryUnitRequest.java | 50 +
.../tajo/engine/query/QueryUnitRequestImpl.java | 328 +
.../apache/tajo/engine/utils/SchemaUtil.java | 72 +
.../apache/tajo/engine/utils/ThreadUtil.java | 149 +
.../apache/tajo/engine/utils/TupleCache.java | 122 +
.../apache/tajo/engine/utils/TupleCacheKey.java | 60 +
.../tajo/engine/utils/TupleCacheScanner.java | 109 +
.../org/apache/tajo/engine/utils/TupleUtil.java | 231 +
.../tajo/master/AbstractTaskScheduler.java | 56 +
.../org/apache/tajo/master/ContainerProxy.java | 81 +
.../DefaultFragmentScheduleAlgorithm.java | 247 +
.../tajo/master/DefaultTaskScheduler.java | 896 ++
.../apache/tajo/master/FetchScheduleEvent.java | 40 +
.../org/apache/tajo/master/FragmentPair.java | 73 +
.../tajo/master/FragmentScheduleAlgorithm.java | 38 +
.../FragmentScheduleAlgorithmFactory.java | 68 +
.../org/apache/tajo/master/GlobalEngine.java | 738 ++
.../master/GreedyFragmentScheduleAlgorithm.java | 421 +
.../apache/tajo/master/LazyTaskScheduler.java | 522 +
.../apache/tajo/master/ScheduledFetches.java | 48 +
.../apache/tajo/master/TajoAsyncDispatcher.java | 232 +
.../apache/tajo/master/TajoContainerProxy.java | 178 +
.../java/org/apache/tajo/master/TajoMaster.java | 579 +
.../tajo/master/TajoMasterClientService.java | 754 ++
.../apache/tajo/master/TajoMasterService.java | 172 +
.../tajo/master/TaskRunnerGroupEvent.java | 51 +
.../apache/tajo/master/TaskRunnerLauncher.java | 25 +
.../tajo/master/TaskSchedulerContext.java | 65 +
.../tajo/master/TaskSchedulerFactory.java | 69 +
.../java/org/apache/tajo/master/TaskState.java | 23 +
.../apache/tajo/master/YarnContainerProxy.java | 414 +
.../tajo/master/YarnTaskRunnerLauncherImpl.java | 200 +
.../apache/tajo/master/cluster/ServerName.java | 123 +
.../master/event/ContainerAllocationEvent.java | 77 +
.../event/ContainerAllocatorEventType.java | 26 +
.../tajo/master/event/ContainerEvent.java | 37 +
.../master/event/FragmentScheduleEvent.java | 61 +
.../event/GrouppedContainerAllocatorEvent.java | 45 +
.../tajo/master/event/LocalTaskEvent.java | 45 +
.../tajo/master/event/LocalTaskEventType.java | 23 +
.../tajo/master/event/QueryCompletedEvent.java | 42 +
.../event/QueryDiagnosticsUpdateEvent.java | 34 +
.../apache/tajo/master/event/QueryEvent.java | 36 +
.../tajo/master/event/QueryEventType.java | 36 +
.../event/QueryMasterQueryCompletedEvent.java | 39 +
.../tajo/master/event/QueryStartEvent.java | 74 +
.../tajo/master/event/QuerySubQueryEvent.java | 35 +
.../event/QueryUnitAttemptScheduleEvent.java | 87 +
.../master/event/SubQueryCompletedEvent.java | 42 +
.../event/SubQueryContainerAllocationEvent.java | 38 +
.../event/SubQueryDiagnosticsUpdateEvent.java | 34 +
.../apache/tajo/master/event/SubQueryEvent.java | 35 +
.../tajo/master/event/SubQueryEventType.java | 43 +
.../tajo/master/event/SubQueryTaskEvent.java | 43 +
.../master/event/TaskAttemptAssignedEvent.java | 48 +
.../tajo/master/event/TaskAttemptEvent.java | 36 +
.../tajo/master/event/TaskAttemptEventType.java | 54 +
.../master/event/TaskAttemptScheduleEvent.java | 37 +
.../event/TaskAttemptStatusUpdateEvent.java | 36 +
.../tajo/master/event/TaskCompletionEvent.java | 35 +
.../org/apache/tajo/master/event/TaskEvent.java | 35 +
.../apache/tajo/master/event/TaskEventType.java | 38 +
.../tajo/master/event/TaskFatalErrorEvent.java | 41 +
.../tajo/master/event/TaskRequestEvent.java | 59 +
.../tajo/master/event/TaskSchedulerEvent.java | 41 +
.../tajo/master/event/TaskTAttemptEvent.java | 34 +
.../master/metrics/CatalogMetricsGaugeSet.java | 56 +
.../metrics/WorkerResourceMetricsGaugeSet.java | 74 +
.../apache/tajo/master/querymaster/Query.java | 702 ++
.../master/querymaster/QueryInProgress.java | 294 +
.../tajo/master/querymaster/QueryInfo.java | 125 +
.../tajo/master/querymaster/QueryJobEvent.java | 44 +
.../master/querymaster/QueryJobManager.java | 195 +
.../tajo/master/querymaster/QueryMaster.java | 504 +
.../querymaster/QueryMasterManagerService.java | 239 +
.../master/querymaster/QueryMasterRunner.java | 149 +
.../master/querymaster/QueryMasterTask.java | 556 +
.../tajo/master/querymaster/QueryUnit.java | 658 +
.../master/querymaster/QueryUnitAttempt.java | 442 +
.../tajo/master/querymaster/Repartitioner.java | 653 +
.../tajo/master/querymaster/SubQuery.java | 1125 ++
.../tajo/master/querymaster/SubQueryState.java | 30 +
.../apache/tajo/master/rm/TajoRMContext.java | 84 +
.../tajo/master/rm/TajoResourceTracker.java | 253 +
.../tajo/master/rm/TajoWorkerContainer.java | 100 +
.../tajo/master/rm/TajoWorkerContainerId.java | 93 +
.../master/rm/TajoWorkerResourceManager.java | 537 +
.../java/org/apache/tajo/master/rm/Worker.java | 296 +
.../org/apache/tajo/master/rm/WorkerEvent.java | 37 +
.../apache/tajo/master/rm/WorkerEventType.java | 30 +
.../tajo/master/rm/WorkerLivelinessMonitor.java | 56 +
.../tajo/master/rm/WorkerReconnectEvent.java | 35 +
.../apache/tajo/master/rm/WorkerResource.java | 235 +
.../tajo/master/rm/WorkerResourceManager.java | 110 +
.../org/apache/tajo/master/rm/WorkerState.java | 44 +
.../tajo/master/rm/WorkerStatusEvent.java | 54 +
.../master/rm/YarnRMContainerAllocator.java | 237 +
.../tajo/master/rm/YarnTajoResourceManager.java | 349 +
.../master/session/InvalidSessionException.java | 25 +
.../session/NoSuchSessionVariableException.java | 25 +
.../org/apache/tajo/master/session/Session.java | 124 +
.../tajo/master/session/SessionConstants.java | 23 +
.../tajo/master/session/SessionEvent.java | 34 +
.../tajo/master/session/SessionEventType.java | 24 +
.../session/SessionLivelinessMonitor.java | 53 +
.../tajo/master/session/SessionManager.java | 139 +
.../org/apache/tajo/net/CachedDNSResolver.java | 64 +
.../apache/tajo/util/ApplicationIdUtils.java | 44 +
.../java/org/apache/tajo/util/ClassUtil.java | 155 +
.../java/org/apache/tajo/util/GeoIPUtil.java | 46 +
.../java/org/apache/tajo/util/IndexUtil.java | 148 +
.../main/java/org/apache/tajo/util/JSPUtil.java | 209 +
.../util/metrics/GroupNameMetricsFilter.java | 43 +
.../tajo/util/metrics/LogEventGaugeSet.java | 64 +
.../tajo/util/metrics/MetricsFilterList.java | 43 +
.../tajo/util/metrics/RegexpMetricsFilter.java | 51 +
.../tajo/util/metrics/TajoLogEventCounter.java | 86 +
.../apache/tajo/util/metrics/TajoMetrics.java | 133 +
.../tajo/util/metrics/TajoSystemMetrics.java | 213 +
.../util/metrics/reporter/GangliaReporter.java | 258 +
.../reporter/MetricsConsoleReporter.java | 80 +
.../MetricsConsoleScheduledReporter.java | 32 +
.../reporter/MetricsFileScheduledReporter.java | 58 +
.../MetricsStreamScheduledReporter.java | 179 +
.../util/metrics/reporter/NullReporter.java | 31 +
.../metrics/reporter/TajoMetricsReporter.java | 232 +
.../reporter/TajoMetricsScheduledReporter.java | 206 +
.../java/org/apache/tajo/webapp/HttpServer.java | 447 +
.../tajo/webapp/QueryExecutorServlet.java | 376 +
.../apache/tajo/webapp/StaticHttpServer.java | 69 +
.../tajo/worker/AbstractResourceAllocator.java | 54 +
.../org/apache/tajo/worker/DeletionService.java | 115 +
.../java/org/apache/tajo/worker/Fetcher.java | 256 +
.../apache/tajo/worker/InterDataRetriever.java | 113 +
.../tajo/worker/PartitionRetrieverHandler.java | 44 +
.../tajo/worker/RangeRetrieverHandler.java | 163 +
.../apache/tajo/worker/ResourceAllocator.java | 29 +
.../org/apache/tajo/worker/TajoQueryEngine.java | 49 +
.../tajo/worker/TajoResourceAllocator.java | 339 +
.../java/org/apache/tajo/worker/TajoWorker.java | 583 +
.../tajo/worker/TajoWorkerClientService.java | 221 +
.../tajo/worker/TajoWorkerManagerService.java | 152 +
.../main/java/org/apache/tajo/worker/Task.java | 762 ++
.../apache/tajo/worker/TaskAttemptContext.java | 270 +
.../org/apache/tajo/worker/TaskHistory.java | 198 +
.../java/org/apache/tajo/worker/TaskRunner.java | 431 +
.../apache/tajo/worker/TaskRunnerManager.java | 238 +
.../tajo/worker/WorkerHeartbeatService.java | 289 +
.../tajo/worker/YarnResourceAllocator.java | 117 +
.../FileAccessForbiddenException.java | 40 +
.../tajo/worker/dataserver/HttpDataServer.java | 87 +
.../dataserver/HttpDataServerHandler.java | 199 +
.../HttpDataServerPipelineFactory.java | 55 +
.../apache/tajo/worker/dataserver/HttpUtil.java | 69 +
.../retriever/AdvancedDataRetriever.java | 128 +
.../dataserver/retriever/DataRetriever.java | 29 +
.../retriever/DirectoryRetriever.java | 56 +
.../worker/dataserver/retriever/FileChunk.java | 51 +
.../dataserver/retriever/RetrieverHandler.java | 33 +
tajo-core/src/main/proto/InternalTypes.proto | 32 +
.../src/main/proto/QueryMasterProtocol.proto | 42 +
.../main/proto/ResourceTrackerProtocol.proto | 40 +
.../src/main/proto/TajoMasterProtocol.proto | 154 +
.../src/main/proto/TajoWorkerProtocol.proto | 258 +
.../src/main/resources/catalog-default.xml | 32 +
tajo-core/src/main/resources/log4j.properties | 28 +
tajo-core/src/main/resources/tajo-default.xml | 50 +
.../src/main/resources/tajo-metrics.properties | 75 +
.../webapps/admin/WEB-INF/jetty-web.xml | 23 +
.../resources/webapps/admin/WEB-INF/web.xml | 27 +
.../resources/webapps/admin/catalogview.jsp | 166 +
.../main/resources/webapps/admin/cluster.jsp | 216 +
.../src/main/resources/webapps/admin/conf.jsp | 56 +
.../src/main/resources/webapps/admin/env.jsp | 67 +
.../main/resources/webapps/admin/functions.jsp | 77 +
.../src/main/resources/webapps/admin/getCSV.jsp | 31 +
.../src/main/resources/webapps/admin/header.jsp | 32 +
.../src/main/resources/webapps/admin/index.jsp | 184 +
.../src/main/resources/webapps/admin/query.jsp | 137 +
.../resources/webapps/admin/query_executor.jsp | 312 +
.../src/main/resources/webapps/admin/thread.jsp | 45 +
.../resources/webapps/static/img/logo_tajo.gif | Bin 0 -> 3025 bytes
.../main/resources/webapps/static/img/on.jpg | Bin 0 -> 636 bytes
.../resources/webapps/static/img/tajo_logo.png | Bin 0 -> 7592 bytes
.../resources/webapps/static/img/tajochar.jpg | Bin 0 -> 325871 bytes
.../static/img/tajochar_catalog_small.jpg | Bin 0 -> 13275 bytes
.../webapps/static/img/tajochar_little.jpg | Bin 0 -> 27712 bytes
.../webapps/static/img/tajochar_middle.jpg | Bin 0 -> 129938 bytes
.../static/img/tajochar_queries_small.jpg | Bin 0 -> 5184 bytes
.../webapps/static/img/tajochar_small.jpg | Bin 0 -> 65024 bytes
.../webapps/static/img/tajochar_title.jpg | Bin 0 -> 40249 bytes
.../webapps/static/img/tajochar_title_small.jpg | Bin 0 -> 10308 bytes
.../static/img/tajochar_worker_small.jpg | Bin 0 -> 13329 bytes
.../webapps/static/js/jquery-ui.min.js | 5 +
.../main/resources/webapps/static/js/jquery.js | 2 +
.../static/js/jquery.jsPlumb-1.3.16-all-min.js | 1 +
.../static/js/jquery.jsPlumb-1.3.16-all.js | 10561 +++++++++++++++++
.../main/resources/webapps/static/queryplan.css | 55 +
.../src/main/resources/webapps/static/style.css | 74 +
.../resources/webapps/worker/WEB-INF/web.xml | 27 +
.../src/main/resources/webapps/worker/conf.jsp | 55 +
.../src/main/resources/webapps/worker/env.jsp | 69 +
.../main/resources/webapps/worker/header.jsp | 37 +
.../src/main/resources/webapps/worker/index.jsp | 150 +
.../resources/webapps/worker/querydetail.jsp | 105 +
.../main/resources/webapps/worker/queryplan.jsp | 237 +
.../resources/webapps/worker/querytasks.jsp | 232 +
.../main/resources/webapps/worker/queryunit.jsp | 171 +
.../resources/webapps/worker/taskcontainers.jsp | 87 +
.../resources/webapps/worker/taskdetail.jsp | 127 +
.../src/main/resources/webapps/worker/tasks.jsp | 94 +
.../main/resources/webapps/worker/thread.jsp | 45 +
tajo-core/src/test/java/log4j.properties | 28 +
.../org/apache/tajo/BackendTestingUtil.java | 76 +
.../java/org/apache/tajo/IntegrationTest.java | 22 +
.../apache/tajo/LocalTajoTestingUtility.java | 136 +
.../org/apache/tajo/MiniTajoYarnCluster.java | 175 +
.../java/org/apache/tajo/QueryTestCaseBase.java | 539 +
.../org/apache/tajo/TajoTestingCluster.java | 630 +
.../org/apache/tajo/TestQueryIdFactory.java | 58 +
.../test/java/org/apache/tajo/TestTajoIds.java | 168 +
.../test/java/org/apache/tajo/TpchTestBase.java | 117 +
.../org/apache/tajo/benchmark/TestTPCH.java | 56 +
.../tajo/cli/TestExecExternalShellCommand.java | 46 +
.../org/apache/tajo/cli/TestHdfsCommand.java | 46 +
.../org/apache/tajo/cli/TestSimpleParser.java | 179 +
.../org/apache/tajo/client/TestDDLBuilder.java | 133 +
.../org/apache/tajo/client/TestTajoClient.java | 666 ++
.../org/apache/tajo/cluster/TestServerName.java | 102 +
.../apache/tajo/engine/eval/ExprTestBase.java | 210 +
.../apache/tajo/engine/eval/TestEvalTree.java | 323 +
.../tajo/engine/eval/TestEvalTreeUtil.java | 359 +
.../apache/tajo/engine/eval/TestPredicates.java | 396 +
.../tajo/engine/eval/TestSQLDateTimeTypes.java | 53 +
.../tajo/engine/eval/TestSQLExpression.java | 206 +
.../tajo/engine/function/TestAggFunction.java | 64 +
.../engine/function/TestBuiltinFunctions.java | 123 +
.../function/TestConditionalExpressions.java | 82 +
.../engine/function/TestDateTimeFunctions.java | 253 +
.../engine/function/TestGeneralFunction.java | 49 +
.../tajo/engine/function/TestMathFunctions.java | 428 +
.../function/TestPatternMatchingPredicates.java | 140 +
.../TestStringOperatorsAndFunctions.java | 610 +
.../tajo/engine/parser/TestHiveQLAnalyzer.java | 271 +
.../tajo/engine/parser/TestSQLAnalyzer.java | 473 +
.../tajo/engine/planner/TestLogicalNode.java | 74 +
.../engine/planner/TestLogicalOptimizer.java | 263 +
.../tajo/engine/planner/TestLogicalPlan.java | 125 +
.../tajo/engine/planner/TestLogicalPlanner.java | 1136 ++
.../tajo/engine/planner/TestPlannerUtil.java | 321 +
.../engine/planner/TestSimpleDirectedGraph.java | 79 +
.../planner/TestSimpleUndirectedGraph.java | 96 +
.../planner/TestUniformRangePartition.java | 442 +
.../planner/global/TestBroadcastJoinPlan.java | 400 +
.../engine/planner/global/TestMasterPlan.java | 53 +
.../planner/physical/TestBNLJoinExec.java | 217 +
.../planner/physical/TestBSTIndexExec.java | 210 +
.../planner/physical/TestExternalSortExec.java | 184 +
.../physical/TestFullOuterHashJoinExec.java | 403 +
.../physical/TestFullOuterMergeJoinExec.java | 536 +
.../planner/physical/TestHashAntiJoinExec.java | 209 +
.../planner/physical/TestHashJoinExec.java | 275 +
.../planner/physical/TestHashPartitioner.java | 84 +
.../planner/physical/TestHashSemiJoinExec.java | 214 +
.../physical/TestLeftOuterHashJoinExec.java | 463 +
.../physical/TestLeftOuterNLJoinExec.java | 474 +
.../planner/physical/TestMergeJoinExec.java | 193 +
.../engine/planner/physical/TestNLJoinExec.java | 209 +
.../planner/physical/TestPhysicalPlanner.java | 1023 ++
.../physical/TestProgressExternalSortExec.java | 233 +
.../physical/TestRightOuterHashJoinExec.java | 350 +
.../physical/TestRightOuterMergeJoinExec.java | 520 +
.../engine/planner/physical/TestSortExec.java | 166 +
.../tajo/engine/query/TestAlterTable.java | 52 +
.../tajo/engine/query/TestAlterTablespace.java | 59 +
.../apache/tajo/engine/query/TestCTASQuery.java | 239 +
.../tajo/engine/query/TestCaseByCases.java | 70 +
.../tajo/engine/query/TestCreateDatabase.java | 75 +
.../tajo/engine/query/TestCreateTable.java | 360 +
.../apache/tajo/engine/query/TestDropTable.java | 38 +
.../tajo/engine/query/TestGroupByQuery.java | 246 +
.../tajo/engine/query/TestInsertQuery.java | 262 +
.../tajo/engine/query/TestJoinBroadcast.java | 377 +
.../query/TestJoinOnPartitionedTables.java | 56 +
.../apache/tajo/engine/query/TestJoinQuery.java | 325 +
.../apache/tajo/engine/query/TestNetTypes.java | 102 +
.../tajo/engine/query/TestNullValues.java | 162 +
.../tajo/engine/query/TestSelectQuery.java | 303 +
.../apache/tajo/engine/query/TestSortQuery.java | 146 +
.../tajo/engine/query/TestTablePartitions.java | 439 +
.../tajo/engine/query/TestTableSubQuery.java | 60 +
.../tajo/engine/query/TestUnionQuery.java | 141 +
.../apache/tajo/engine/util/TestTupleCache.java | 89 +
.../apache/tajo/engine/util/TestTupleUtil.java | 171 +
.../org/apache/tajo/jdbc/TestResultSet.java | 127 +
.../tajo/jdbc/TestTajoDatabaseMetaData.java | 355 +
.../java/org/apache/tajo/jdbc/TestTajoJdbc.java | 386 +
.../tajo/master/TestExecutionBlockCursor.java | 123 +
.../apache/tajo/master/TestGlobalPlanner.java | 205 +
.../apache/tajo/master/TestRepartitioner.java | 77 +
.../querymaster/TestQueryUnitStatusUpdate.java | 175 +
.../tajo/master/rm/TestTajoResourceManager.java | 378 +
.../apache/tajo/storage/TestFileFragment.java | 93 +
.../org/apache/tajo/storage/TestRowFile.java | 145 +
.../java/org/apache/tajo/util/TestJSPUtil.java | 84 +
.../tajo/util/metrics/TestMetricsFilter.java | 52 +
.../tajo/util/metrics/TestSystemMetrics.java | 133 +
.../org/apache/tajo/worker/TestFetcher.java | 94 +
.../tajo/worker/TestRangeRetrieverHandler.java | 373 +
.../worker/dataserver/TestHttpDataServer.java | 172 +
.../tajo/worker/dataserver/TestHttpUtil.java | 49 +
.../resources/dataset/TestAlterTable/table1.tbl | 3 +
.../dataset/TestCreateTable/table1/table1.tbl | 3 +
.../dataset/TestCreateTable/table2/table2.tbl | 3 +
.../resources/dataset/TestDropTable/table1.tbl | 3 +
.../customer_large/customer.tbl | 100 +
.../lineitem_large/lineitem.tbl | 97 +
.../dataset/TestJoinQuery/table1/table1.tbl | 5 +
.../dataset/TestJoinQuery/table2/table2.tbl | 4 +
.../dataset/TestNetTypes/table1/table1.tbl | 5 +
.../dataset/TestNetTypes/table2/table2.tbl | 5 +
.../dataset/TestSortQuery/table1/table1.tbl | 5 +
.../dataset/TestSortQuery/table2/table2.tbl | 24 +
tajo-core/src/test/resources/log4j.properties | 28 +
.../org/apache/tajo/client/TestTajoDump.java | 44 +
.../alter_table_add_new_column_ddl.sql | 1 +
.../alter_table_rename_column_ddl.sql | 1 +
.../alter_table_rename_table_ddl.sql | 1 +
.../queries/TestAlterTable/table1_ddl.sql | 1 +
.../TestBuiltinFunctions/testAvgDouble.sql | 1 +
.../queries/TestBuiltinFunctions/testAvgInt.sql | 1 +
.../TestBuiltinFunctions/testAvgLong.sql | 1 +
.../queries/TestBuiltinFunctions/testCount.sql | 1 +
.../TestBuiltinFunctions/testMaxLong.sql | 1 +
.../TestBuiltinFunctions/testMaxString.sql | 1 +
.../TestBuiltinFunctions/testMinLong.sql | 1 +
.../TestBuiltinFunctions/testMinString.sql | 1 +
.../queries/TestBuiltinFunctions/testRandom.sql | 1 +
.../TestBuiltinFunctions/testSplitPart.sql | 1 +
.../testSplitPartByString.sql | 1 +
.../testSplitPartNested.sql | 1 +
.../queries/TestCTASQuery/CtasWithGroupby.sql | 2 +
.../queries/TestCTASQuery/CtasWithLimit.sql | 13 +
.../TestCTASQuery/CtasWithManagedTable.sql | 12 +
.../queries/TestCTASQuery/CtasWithOptions.sql | 13 +
.../queries/TestCTASQuery/CtasWithOrderby.sql | 11 +
.../queries/TestCTASQuery/CtasWithStoreType.sql | 12 +
.../queries/TestCTASQuery/CtasWithUnion.sql | 35 +
.../resources/queries/TestCTASQuery/check1.sql | 1 +
.../resources/queries/TestCTASQuery/check2.sql | 1 +
.../testCtasWithColumnedPartition.sql | 2 +
.../TestCTASQuery/testCtasWithGroupby.sql | 1 +
.../queries/TestCTASQuery/testCtasWithLimit.sql | 1 +
.../TestCTASQuery/testCtasWithOptions.sql | 1 +
.../TestCTASQuery/testCtasWithOrderby.sql | 1 +
.../TestCTASQuery/testCtasWithStoreType.sql | 1 +
.../queries/TestCTASQuery/testCtasWithUnion.sql | 1 +
.../testCtasWithoutTableDefinition.sql | 2 +
.../queries/TestCaseByCases/testTAJO415Case.sql | 36 +
.../queries/TestCaseByCases/testTAJO418Case.sql | 29 +
.../queries/TestCaseByCases/testTAJO619Case.sql | 4 +
.../queries/TestCaseByCases/testTAJO718Case.sql | 10 +
.../queries/TestCaseByCases/testTAJO739Case.sql | 5 +
.../create_table_various_types.sql | 50 +
.../create_table_various_types_for_hcatalog.sql | 50 +
.../quoted_identifier_mixed_chars_1.sql | 1 +
.../quoted_identifier_mixed_chars_2.sql | 1 +
.../quoted_identifier_mixed_chars_3.sql | 22 +
.../quoted_identifier_mixed_chars_ddl_1.sql | 1 +
.../quoted_identifier_mixed_chars_ddl_2.sql | 1 +
.../quoted_identifier_non_ascii_1.sql | 1 +
.../quoted_identifier_non_ascii_2.sql | 1 +
.../quoted_identifier_non_ascii_3.sql | 1 +
.../quoted_identifier_non_ascii_ddl.sql | 1 +
.../queries/TestCreateTable/table1_ddl.sql | 1 +
.../queries/TestDropTable/drop_table_ddl.sql | 1 +
.../queries/TestDropTable/table1_ddl.sql | 1 +
.../TestGroupByQuery/testComplexParameter.sql | 1 +
.../TestGroupByQuery/testComplexParameter2.sql | 1 +
.../testComplexParameterWithSubQuery.sql | 6 +
.../testDistinctAggregation1.sql | 1 +
.../testDistinctAggregation2.sql | 1 +
.../testDistinctAggregation3.sql | 1 +
.../testDistinctAggregation4.sql | 1 +
.../testDistinctAggregation5.sql | 1 +
.../testDistinctAggregation6.sql | 9 +
.../testDistinctAggregationWithHaving1.sql | 1 +
.../testDistinctAggregationWithUnion1.sql | 21 +
.../queries/TestGroupByQuery/testGroupBy.sql | 1 +
.../queries/TestGroupByQuery/testGroupBy2.sql | 1 +
.../queries/TestGroupByQuery/testGroupBy3.sql | 1 +
.../queries/TestGroupByQuery/testGroupBy4.sql | 9 +
.../queries/TestGroupByQuery/testGroupBy5.sql | 1 +
.../TestGroupByQuery/testGroupByNested1.sql | 8 +
.../TestGroupByQuery/testGroupByNested2.sql | 10 +
.../testGroupByWithConstantKeys1.sql | 1 +
.../testGroupByWithExpressionKeys1.sql | 1 +
.../testGroupByWithExpressionKeys2.sql | 1 +
.../testGroupByWithSameExprs1.sql | 6 +
.../testGroupByWithSameExprs2.sql | 6 +
.../testHavingWithAggFunction.sql | 1 +
.../testHavingWithNamedTarget.sql | 1 +
.../create_customer_large_ddl.sql | 7 +
.../create_lineitem_large_ddl.sql | 7 +
.../queries/TestJoinBroadcast/oj_table1_ddl.sql | 6 +
.../queries/TestJoinBroadcast/oj_table2_ddl.sql | 6 +
.../testBroadcastBasicJoin.sql | 11 +
.../TestJoinBroadcast/testBroadcastSubquery.sql | 11 +
.../testBroadcastSubquery2.sql | 19 +
.../testBroadcastTwoPartJoin.sql | 15 +
.../queries/TestJoinBroadcast/testCrossJoin.sql | 1 +
.../testCrossJoinAndCaseWhen.sql | 18 +
.../testCrossJoinWithAsterisk1.sql | 1 +
.../testCrossJoinWithAsterisk2.sql | 1 +
.../testCrossJoinWithAsterisk3.sql | 1 +
.../testCrossJoinWithAsterisk4.sql | 1 +
.../testCrossJoinWithEmptyTable1.sql | 8 +
.../TestJoinBroadcast/testFullOuterJoin1.sql | 8 +
.../testFullOuterJoinWithEmptyTable1.sql | 8 +
.../testInnerJoinWithEmptyTable.sql | 8 +
.../testJoinCoReferredEvals1.sql | 11 +
.../testJoinCoReferredEvalsWithSameExprs1.sql | 14 +
.../testJoinCoReferredEvalsWithSameExprs2.sql | 22 +
.../testJoinOnMultipleDatabases.sql | 25 +
.../TestJoinBroadcast/testLeftOuterJoin1.sql | 9 +
.../testLeftOuterJoinWithConstantExpr1.sql | 9 +
.../testLeftOuterJoinWithConstantExpr2.sql | 9 +
.../testLeftOuterJoinWithConstantExpr3.sql | 17 +
.../testLeftOuterJoinWithEmptyTable1.sql | 9 +
.../testLeftOuterJoinWithEmptyTable2.sql | 9 +
.../testLeftOuterJoinWithEmptyTable3.sql | 14 +
.../testLeftOuterJoinWithEmptyTable4.sql | 17 +
.../testOuterJoinAndCaseWhen1.sql | 12 +
.../TestJoinBroadcast/testRightOuterJoin1.sql | 8 +
.../testRightOuterJoinWithEmptyTable1.sql | 8 +
.../TestJoinBroadcast/testTPCHQ2Join.sql | 25 +
.../TestJoinBroadcast/testWhereClauseJoin1.sql | 10 +
.../TestJoinBroadcast/testWhereClauseJoin2.sql | 8 +
.../TestJoinBroadcast/testWhereClauseJoin3.sql | 9 +
.../TestJoinBroadcast/testWhereClauseJoin4.sql | 8 +
.../TestJoinBroadcast/testWhereClauseJoin5.sql | 15 +
.../TestJoinBroadcast/testWhereClauseJoin6.sql | 19 +
.../customer_ddl.sql | 9 +
.../insert_into_customer.sql | 11 +
.../selfJoinOfPartitionedTable.sql | 9 +
.../testNoProjectionJoinQual.sql | 1 +
.../testPartialFilterPushDown.sql | 9 +
.../testPartitionTableJoinSmallTable.sql | 11 +
.../queries/TestJoinQuery/oj_table1_ddl.sql | 6 +
.../queries/TestJoinQuery/oj_table2_ddl.sql | 6 +
.../queries/TestJoinQuery/testCrossJoin.sql | 1 +
.../TestJoinQuery/testCrossJoinAndCaseWhen.sql | 18 +
.../testCrossJoinWithAsterisk1.sql | 1 +
.../testCrossJoinWithAsterisk2.sql | 1 +
.../testCrossJoinWithAsterisk3.sql | 1 +
.../testCrossJoinWithAsterisk4.sql | 1 +
.../testCrossJoinWithEmptyTable1.sql | 8 +
.../TestJoinQuery/testFullOuterJoin1.sql | 8 +
.../testFullOuterJoinWithEmptyTable1.sql | 8 +
.../testInnerJoinWithEmptyTable.sql | 8 +
.../TestJoinQuery/testJoinCoReferredEvals1.sql | 11 +
.../testJoinCoReferredEvalsWithSameExprs1.sql | 14 +
.../testJoinCoReferredEvalsWithSameExprs2.sql | 22 +
.../testJoinOnMultipleDatabases.sql | 25 +
.../TestJoinQuery/testLeftOuterJoin1.sql | 9 +
.../testLeftOuterJoinWithConstantExpr1.sql | 9 +
.../testLeftOuterJoinWithConstantExpr2.sql | 9 +
.../testLeftOuterJoinWithConstantExpr3.sql | 17 +
.../testLeftOuterJoinWithEmptyTable1.sql | 9 +
.../testLeftOuterJoinWithEmptyTable2.sql | 9 +
.../testLeftOuterJoinWithEmptyTable3.sql | 14 +
.../testLeftOuterJoinWithEmptyTable4.sql | 17 +
.../TestJoinQuery/testOuterJoinAndCaseWhen1.sql | 12 +
.../TestJoinQuery/testRightOuterJoin1.sql | 8 +
.../testRightOuterJoinWithEmptyTable1.sql | 8 +
.../queries/TestJoinQuery/testTPCHQ2Join.sql | 25 +
.../TestJoinQuery/testWhereClauseJoin1.sql | 10 +
.../TestJoinQuery/testWhereClauseJoin2.sql | 8 +
.../TestJoinQuery/testWhereClauseJoin3.sql | 9 +
.../TestJoinQuery/testWhereClauseJoin4.sql | 8 +
.../TestJoinQuery/testWhereClauseJoin5.sql | 15 +
.../TestJoinQuery/testWhereClauseJoin6.sql | 19 +
.../queries/TestNetTypes/table1_ddl.sql | 4 +
.../queries/TestNetTypes/table2_ddl.sql | 4 +
.../queries/TestNetTypes/testGroupby.sql | 8 +
.../queries/TestNetTypes/testGroupby2.sql | 9 +
.../resources/queries/TestNetTypes/testJoin.sql | 1 +
.../queries/TestNetTypes/testSelect.sql | 1 +
.../resources/queries/TestNetTypes/testSort.sql | 1 +
.../queries/TestNetTypes/testSort2.sql | 1 +
.../queries/TestQueryUnitStatusUpdate/case1.sql | 1 +
.../queries/TestQueryUnitStatusUpdate/case2.sql | 5 +
.../queries/TestQueryUnitStatusUpdate/case3.sql | 11 +
.../queries/TestSelectQuery/testCaseWhen.sql | 11 +
.../TestSelectQuery/testCaseWhenWithoutElse.sql | 10 +
.../TestSelectQuery/testCreateAfterSelect.sql | 1 +
.../TestSelectQuery/testDatabaseRef1.sql | 1 +
.../TestSelectQuery/testDatabaseRef2.sql | 1 +
.../TestSelectQuery/testDatabaseRef3.sql | 1 +
.../TestSelectQuery/testExplainSelect.sql | 1 +
.../queries/TestSelectQuery/testInClause.sql | 1 +
.../queries/TestSelectQuery/testInStrClause.sql | 1 +
.../queries/TestSelectQuery/testLikeClause.sql | 1 +
.../queries/TestSelectQuery/testLimit.sql | 1 +
.../TestSelectQuery/testNonFromSelect1.sql | 1 +
.../queries/TestSelectQuery/testNotEqual.sql | 1 +
.../queries/TestSelectQuery/testNotInClause.sql | 1 +
.../TestSelectQuery/testNotInStrClause.sql | 1 +
.../TestSelectQuery/testRealValueCompare.sql | 1 +
.../queries/TestSelectQuery/testSelect.sql | 1 +
.../queries/TestSelectQuery/testSelect2.sql | 1 +
.../queries/TestSelectQuery/testSelect3.sql | 1 +
.../TestSelectQuery/testSelectAsterik.sql | 1 +
.../TestSelectQuery/testSelectAsterisk1.sql | 1 +
.../TestSelectQuery/testSelectAsterisk2.sql | 1 +
.../TestSelectQuery/testSelectAsterisk3.sql | 1 +
.../TestSelectQuery/testSelectAsterisk4.sql | 1 +
.../TestSelectQuery/testSelectAsterisk5.sql | 1 +
.../TestSelectQuery/testSelectColumnAlias1.sql | 1 +
.../TestSelectQuery/testSelectDistinct.sql | 7 +
...tSelectSameConstantsWithDifferentAliases.sql | 1 +
.../testSelectSameExprsWithDifferentAliases.sql | 1 +
.../queries/TestSelectQuery/testSimpleQuery.sql | 1 +
.../testSimpleQueryWithLimit.sql | 1 +
.../TestSelectQuery/testStringCompare.sql | 1 +
.../queries/TestSelectQuery/testWhereCond1.sql | 1 +
.../TestSelectQuery/testWhereCondWithAlias1.sql | 1 +
.../TestSelectQuery/testWhereCondWithAlias2.sql | 1 +
.../create_table_with_asc_desc_keys.sql | 1 +
.../create_table_with_date_ddl.sql | 10 +
.../queries/TestSortQuery/testAsterisk.sql | 1 +
.../queries/TestSortQuery/testSort.sql | 1 +
.../TestSortQuery/testSortAfterGroupby.sql | 1 +
.../testSortAfterGroupbyWithAlias.sql | 1 +
.../queries/TestSortQuery/testSortDesc.sql | 1 +
.../TestSortQuery/testSortWithAlias1.sql | 1 +
.../TestSortQuery/testSortWithAlias2.sql | 9 +
.../TestSortQuery/testSortWithAlias3.sql | 11 +
.../testSortWithAliasButOriginalName.sql | 1 +
.../TestSortQuery/testSortWithAscDescKeys.sql | 1 +
.../queries/TestSortQuery/testSortWithDate.sql | 1 +
.../queries/TestSortQuery/testSortWithExpr1.sql | 1 +
.../queries/TestSortQuery/testSortWithExpr2.sql | 1 +
.../queries/TestSortQuery/testTopK.sql | 1 +
.../queries/TestTPCH/testQ1OrderBy.sql | 12 +
.../queries/TestTPCH/testQ2FourJoins.sql | 18 +
.../queries/TestTPCH/testTPCH14Expr.sql | 12 +
.../queries/TestTablePartitions/case1.sql | 16 +
.../queries/TestTablePartitions/case2.sql | 31 +
.../queries/TestTablePartitions/case3.sql | 8 +
.../TestTableSubQuery/testGroupBySubQuery.sql | 1 +
.../TestTableSubQuery/testJoinSubQuery.sql | 5 +
.../TestTableSubQuery/testJoinSubQuery2.sql | 4 +
.../TestTableSubQuery/testTableSubquery1.sql | 1 +
.../queries/TestUnionQuery/testUnion1.sql | 19 +
.../queries/TestUnionQuery/testUnion10.sql | 158 +
.../queries/TestUnionQuery/testUnion2.sql | 18 +
.../queries/TestUnionQuery/testUnion3.sql | 19 +
.../queries/TestUnionQuery/testUnion4.sql | 16 +
.../queries/TestUnionQuery/testUnion5.sql | 20 +
.../queries/TestUnionQuery/testUnion6.sql | 15 +
.../queries/TestUnionQuery/testUnion7.sql | 18 +
.../queries/TestUnionQuery/testUnion8.sql | 24 +
.../queries/TestUnionQuery/testUnion9.sql | 29 +
.../testUnionWithSameAliasNames.sql | 25 +
.../resources/queries/default/asterisk_1.sql | 1 +
.../resources/queries/default/asterisk_2.sql | 1 +
.../resources/queries/default/asterisk_3.sql | 1 +
.../resources/queries/default/asterisk_4.sql | 1 +
.../queries/default/complex_union_1.sql | 29 +
.../queries/default/complex_union_2.sql | 35 +
.../create_partitioned_table_as_select.sql | 17 +
.../queries/default/create_table_1.hiveql | 1 +
.../queries/default/create_table_1.sql | 1 +
.../queries/default/create_table_10.sql | 1 +
.../queries/default/create_table_11.hiveql | 3 +
.../queries/default/create_table_11.sql | 3 +
.../queries/default/create_table_12.hiveql | 4 +
.../queries/default/create_table_12.sql | 3 +
.../queries/default/create_table_2.hiveql | 1 +
.../queries/default/create_table_2.sql | 1 +
.../queries/default/create_table_3.sql | 1 +
.../queries/default/create_table_4.sql | 1 +
.../queries/default/create_table_5.sql | 1 +
.../queries/default/create_table_6.sql | 1 +
.../queries/default/create_table_7.sql | 1 +
.../queries/default/create_table_8.sql | 48 +
.../queries/default/create_table_9.sql | 1 +
.../create_table_partition_by_column.sql | 4 +
.../create_table_partition_by_hash_1.sql | 3 +
.../create_table_partition_by_hash_2.sql | 7 +
.../default/create_table_partition_by_list.sql | 8 +
.../default/create_table_partition_by_range.sql | 9 +
.../resources/queries/default/drop_table.sql | 1 +
.../queries/default/exists_predicate_1.sql | 1 +
.../queries/default/exists_predicate_2.sql | 1 +
.../resources/queries/default/groupby_1.sql | 1 +
.../resources/queries/default/groupby_2.sql | 1 +
.../resources/queries/default/groupby_3.sql | 1 +
.../resources/queries/default/groupby_4.sql | 1 +
.../resources/queries/default/groupby_5.sql | 1 +
.../resources/queries/default/in_subquery_1.sql | 1 +
.../resources/queries/default/in_subquery_2.sql | 1 +
.../queries/default/insert_into_select_1.sql | 1 +
.../queries/default/insert_into_select_2.sql | 1 +
.../queries/default/insert_into_select_3.sql | 1 +
.../default/insert_overwrite_into_select_1.sql | 1 +
.../insert_overwrite_into_select_2.hiveql | 1 +
.../default/insert_overwrite_into_select_2.sql | 1 +
.../default/insert_overwrite_into_select_3.sql | 1 +
.../test/resources/queries/default/join_1.sql | 1 +
.../test/resources/queries/default/join_10.sql | 1 +
.../test/resources/queries/default/join_11.sql | 1 +
.../test/resources/queries/default/join_12.sql | 1 +
.../test/resources/queries/default/join_13.sql | 13 +
.../test/resources/queries/default/join_14.sql | 1 +
.../resources/queries/default/join_15.hiveql | 1 +
.../test/resources/queries/default/join_15.sql | 1 +
.../test/resources/queries/default/join_2.sql | 1 +
.../test/resources/queries/default/join_3.sql | 1 +
.../test/resources/queries/default/join_4.sql | 1 +
.../test/resources/queries/default/join_5.sql | 1 +
.../test/resources/queries/default/join_6.sql | 1 +
.../test/resources/queries/default/join_7.sql | 1 +
.../test/resources/queries/default/join_8.sql | 13 +
.../test/resources/queries/default/join_9.sql | 5 +
.../test/resources/queries/default/select_1.sql | 1 +
.../resources/queries/default/select_10.hiveql | 5 +
.../resources/queries/default/select_10.sql | 5 +
.../resources/queries/default/select_11.hiveql | 4 +
.../resources/queries/default/select_11.sql | 6 +
.../resources/queries/default/select_12.hiveql | 3 +
.../resources/queries/default/select_13.hiveql | 2 +
.../resources/queries/default/select_13.sql | 2 +
.../resources/queries/default/select_14.sql | 2 +
.../resources/queries/default/select_15.hiveql | 1 +
.../resources/queries/default/select_15.sql | 1 +
.../test/resources/queries/default/select_2.sql | 1 +
.../test/resources/queries/default/select_3.sql | 1 +
.../test/resources/queries/default/select_4.sql | 1 +
.../test/resources/queries/default/select_5.sql | 1 +
.../test/resources/queries/default/select_6.sql | 1 +
.../test/resources/queries/default/select_7.sql | 1 +
.../test/resources/queries/default/select_8.sql | 1 +
.../resources/queries/default/select_9.hiveql | 4 +
.../test/resources/queries/default/select_9.sql | 4 +
.../test/resources/queries/default/set_1.sql | 1 +
.../test/resources/queries/default/set_2.sql | 1 +
.../test/resources/queries/default/set_3.sql | 1 +
.../test/resources/queries/default/set_4.sql | 36 +
.../queries/default/table_subquery1.sql | 19 +
.../queries/default/table_subquery2.sql | 21 +
.../resources/queries/default/union_1.hiveql | 14 +
.../TestBuiltinFunctions/testAvgDouble.result | 5 +
.../TestBuiltinFunctions/testAvgInt.result | 3 +
.../TestBuiltinFunctions/testAvgLong.result | 3 +
.../TestBuiltinFunctions/testCount.result | 3 +
.../TestBuiltinFunctions/testMaxLong.result | 3 +
.../TestBuiltinFunctions/testMaxString.result | 3 +
.../TestBuiltinFunctions/testMinLong.result | 3 +
.../TestBuiltinFunctions/testMinString.result | 3 +
.../TestBuiltinFunctions/testSplitPart.result | 7 +
.../testSplitPartByString.result | 7 +
.../testSplitPartNested.result | 7 +
.../TestCTASQuery/testCtasWithGroupby.result | 7 +
.../TestCTASQuery/testCtasWithLimit.result | 5 +
.../TestCTASQuery/testCtasWithOptions.result | 5 +
.../TestCTASQuery/testCtasWithOrderby.result | 7 +
.../TestCTASQuery/testCtasWithStoreType.result | 5 +
.../TestCTASQuery/testCtasWithUnion.result | 8 +
.../TestCaseByCases/testTAJO415Case.result | 7 +
.../TestCaseByCases/testTAJO418Case.result | 3 +
.../TestCaseByCases/testTAJO619Case.result | 3 +
.../TestCaseByCases/testTAJO718Case.result | 5 +
.../TestCaseByCases/testTAJO739Case.result | 7 +
.../quoted_identifier_mixed_chars_1.result | 5 +
.../quoted_identifier_mixed_chars_2.result | 5 +
.../quoted_identifier_mixed_chars_3.result | 8 +
.../quoted_identifier_non_ascii_1.result | 5 +
.../quoted_identifier_non_ascii_2.result | 5 +
.../quoted_identifier_non_ascii_3.result | 5 +
.../testComplexParameter.result | 3 +
.../testComplexParameter2.result | 3 +
.../testComplexParameterWithSubQuery.result | 3 +
.../testDistinctAggregation1.result | 5 +
.../testDistinctAggregation2.result | 5 +
.../testDistinctAggregation3.result | 3 +
.../testDistinctAggregation4.result | 4 +
.../testDistinctAggregation5.result | 4 +
.../testDistinctAggregation6.result | 5 +
.../testDistinctAggregationWithHaving1.result | 3 +
.../testDistinctAggregationWithUnion1.result | 4 +
.../results/TestGroupByQuery/testGroupBy.result | 3 +
.../TestGroupByQuery/testGroupBy2.result | 4 +
.../TestGroupByQuery/testGroupBy3.result | 5 +
.../TestGroupByQuery/testGroupBy4.result | 5 +
.../TestGroupByQuery/testGroupBy5.result | 5 +
.../TestGroupByQuery/testGroupByNested1.result | 6 +
.../TestGroupByQuery/testGroupByNested2.result | 6 +
.../testGroupByWithExpressionKeys1.result | 5 +
.../testGroupByWithExpressionKeys2.result | 5 +
.../testGroupByWithSameExprs1.result | 6 +
.../testGroupByWithSameExprs2.result | 6 +
.../testHavingWithAggFunction.result | 4 +
.../testHavingWithNamedTarget.result | 5 +
.../testBroadcastBasicJoin.result | 99 +
.../testBroadcastSubquery.result | 15 +
.../testBroadcastSubquery2.result | 3 +
.../testBroadcastTwoPartJoin.result | 15 +
.../TestJoinBroadcast/testCrossJoin.result | 127 +
.../testCrossJoinAndCaseWhen.result | 27 +
.../testCrossJoinWithAsterisk1.result | 27 +
.../testCrossJoinWithAsterisk2.result | 27 +
.../testCrossJoinWithAsterisk3.result | 27 +
.../testCrossJoinWithAsterisk4.result | 27 +
.../testCrossJoinWithEmptyTable1.result | 2 +
.../TestJoinBroadcast/testFullOuterJoin1.result | 7 +
.../testFullOuterJoinWithEmptyTable1.result | 7 +
.../testInnerJoinWithEmptyTable.result | 2 +
.../testJoinCoReferredEvals1.result | 27 +
...testJoinCoReferredEvalsWithSameExprs1.result | 22 +
...testJoinCoReferredEvalsWithSameExprs2.result | 22 +
.../testJoinOnMultipleDatabases.result | 5 +
.../TestJoinBroadcast/testLeftOuterJoin1.result | 7 +
.../testLeftOuterJoinWithConstantExpr1.result | 7 +
.../testLeftOuterJoinWithConstantExpr2.result | 7 +
.../testLeftOuterJoinWithConstantExpr3.result | 7 +
.../testLeftOuterJoinWithEmptyTable1.result | 7 +
.../testLeftOuterJoinWithEmptyTable2.result | 7 +
.../testLeftOuterJoinWithEmptyTable3.result | 7 +
.../testLeftOuterJoinWithEmptyTable4.result | 4 +
.../testOuterJoinAndCaseWhen1.result | 7 +
.../testRightOuterJoin1.result | 7 +
.../testRightOuterJoinWithEmptyTable1.result | 7 +
.../TestJoinBroadcast/testTPCHQ2Join.result | 5 +
.../testWhereClauseJoin1.result | 27 +
.../testWhereClauseJoin2.result | 27 +
.../testWhereClauseJoin3.result | 27 +
.../testWhereClauseJoin4.result | 27 +
.../testWhereClauseJoin5.result | 5 +
.../selfJoinOfPartitionedTable.result | 7 +
.../testNoProjectionJoinQual.result | 3 +
.../testPartialFilterPushDown.result | 3 +
.../testPartitionTableJoinSmallTable.result | 7 +
.../results/TestJoinQuery/testCrossJoin.result | 127 +
.../testCrossJoinAndCaseWhen.result | 27 +
.../testCrossJoinWithAsterisk1.result | 27 +
.../testCrossJoinWithAsterisk2.result | 27 +
.../testCrossJoinWithAsterisk3.result | 27 +
.../testCrossJoinWithAsterisk4.result | 27 +
.../testCrossJoinWithEmptyTable1.result | 2 +
.../TestJoinQuery/testFullOuterJoin1.result | 7 +
.../testFullOuterJoinWithEmptyTable1.result | 7 +
.../testInnerJoinWithEmptyTable.result | 2 +
.../testJoinCoReferredEvals1.result | 27 +
...testJoinCoReferredEvalsWithSameExprs1.result | 22 +
...testJoinCoReferredEvalsWithSameExprs2.result | 22 +
.../testJoinOnMultipleDatabases.result | 5 +
.../TestJoinQuery/testLeftOuterJoin1.result | 7 +
.../testLeftOuterJoinWithConstantExpr1.result | 7 +
.../testLeftOuterJoinWithConstantExpr2.result | 7 +
.../testLeftOuterJoinWithConstantExpr3.result | 7 +
.../testLeftOuterJoinWithEmptyTable1.result | 7 +
.../testLeftOuterJoinWithEmptyTable2.result | 7 +
.../testLeftOuterJoinWithEmptyTable3.result | 7 +
.../testLeftOuterJoinWithEmptyTable4.result | 4 +
.../testOuterJoinAndCaseWhen1.result | 7 +
.../TestJoinQuery/testRightOuterJoin1.result | 7 +
.../testRightOuterJoinWithEmptyTable1.result | 7 +
.../results/TestJoinQuery/testTPCHQ2Join.result | 5 +
.../TestJoinQuery/testWhereClauseJoin1.result | 27 +
.../TestJoinQuery/testWhereClauseJoin2.result | 27 +
.../TestJoinQuery/testWhereClauseJoin3.result | 27 +
.../TestJoinQuery/testWhereClauseJoin4.result | 27 +
.../TestJoinQuery/testWhereClauseJoin5.result | 5 +
.../results/TestNetTypes/testGroupby.result | 7 +
.../results/TestNetTypes/testGroupby2.result | 5 +
.../results/TestNetTypes/testJoin.result | 6 +
.../results/TestNetTypes/testSelect.result | 7 +
.../results/TestNetTypes/testSort.result | 7 +
.../results/TestNetTypes/testSort2.result | 6 +
.../results/TestSelectQuery/testCaseWhen.result | 7 +
.../testCaseWhenWithoutElse.result | 7 +
.../TestSelectQuery/testDatabaseRef.result | 7 +
.../TestSelectQuery/testExplainSelect.result | 6 +
.../results/TestSelectQuery/testInClause.result | 5 +
.../TestSelectQuery/testInStrClause.result | 4 +
.../TestSelectQuery/testLikeClause.result | 9 +
.../results/TestSelectQuery/testLimit.result | 5 +
.../TestSelectQuery/testNonFromSelect1.result | 3 +
.../results/TestSelectQuery/testNotEqual.result | 5 +
.../TestSelectQuery/testNotInClause.result | 4 +
.../TestSelectQuery/testNotInStrClause.result | 4 +
.../TestSelectQuery/testRealValueCompare.result | 3 +
.../results/TestSelectQuery/testSelect.result | 7 +
.../results/TestSelectQuery/testSelect2.result | 7 +
.../results/TestSelectQuery/testSelect3.result | 7 +
.../TestSelectQuery/testSelectAsterisk1.result | 7 +
.../TestSelectQuery/testSelectAsterisk2.result | 3 +
.../TestSelectQuery/testSelectAsterisk3.result | 3 +
.../TestSelectQuery/testSelectAsterisk4.result | 7 +
.../TestSelectQuery/testSelectAsterisk5.result | 3 +
.../testSelectColumnAlias1.result | 7 +
.../TestSelectQuery/testSelectDistinct.result | 7 +
...lectSameConstantsWithDifferentAliases.result | 7 +
...stSelectSameExprsWithDifferentAliases.result | 7 +
.../TestSelectQuery/testSimpleQuery.result | 7 +
.../testSimpleQueryWithLimit.result | 5 +
.../TestSelectQuery/testStringCompare.result | 5 +
.../results/TestSelectQuery/testUnion1.result | 10 +
.../results/TestSelectQuery/testUnion2.result | 12 +
.../TestSelectQuery/testWhereCond1.result | 3 +
.../testWhereCondWithAlias1.result | 4 +
.../testWhereCondWithAlias2.result | 4 +
.../results/TestSortQuery/testAsterisk.result | 7 +
.../results/TestSortQuery/testSort.result | 7 +
.../TestSortQuery/testSortAfterGroupby.result | 5 +
.../testSortAfterGroupbyWithAlias.result | 5 +
.../results/TestSortQuery/testSortDesc.result | 7 +
.../TestSortQuery/testSortWithAlias1.result | 7 +
.../TestSortQuery/testSortWithAlias2.result | 5 +
.../TestSortQuery/testSortWithAlias3.result | 7 +
.../testSortWithAliasButOriginalName.result | 7 +
.../testSortWithAscDescKeys.result | 26 +
.../TestSortQuery/testSortWithDate.result | 7 +
.../TestSortQuery/testSortWithExpr1.result | 7 +
.../TestSortQuery/testSortWithExpr2.result | 7 +
.../results/TestSortQuery/testTopK.result | 5 +
.../results/TestTPCH/testQ1OrderBy.result | 4 +
.../results/TestTPCH/testQ2FourJoins.result | 3 +
.../results/TestTPCH/testTPCH14Expr.result | 3 +
.../results/TestTablePartitions/case1.result | 4 +
.../results/TestTablePartitions/case2.result | 6 +
.../results/TestTablePartitions/case3.result | 5 +
.../testGroupBySubQuery.result | 3 +
.../TestTableSubQuery/testJoinSubQuery.result | 4 +
.../TestTableSubQuery/testJoinSubQuery2.result | 4 +
.../TestTableSubQuery/testTableSubquery1.result | 7 +
.../TestTajoDatabaseMetaData/getTables1.result | 4 +
.../TestTajoDatabaseMetaData/getTables2.result | 4 +
.../results/TestTajoDump/testDump1.result | 17 +
.../results/TestUnionQuery/testUnion1.result | 10 +
.../results/TestUnionQuery/testUnion10.result | 22 +
.../results/TestUnionQuery/testUnion2.result | 12 +
.../results/TestUnionQuery/testUnion3.result | 4 +
.../results/TestUnionQuery/testUnion4.result | 3 +
.../results/TestUnionQuery/testUnion5.result | 3 +
.../results/TestUnionQuery/testUnion6.result | 3 +
.../results/TestUnionQuery/testUnion7.result | 12 +
.../results/TestUnionQuery/testUnion8.result | 3 +
.../results/TestUnionQuery/testUnion9.result | 7 +
.../testUnionWithSameAliasNames.result | 12 +
.../testBuildDDLForBaseTable.result | 5 +
.../testBuildDDLForExternalTable.result | 5 +
.../testBuildDDLQuotedTableName1.result | 5 +
.../testBuildDDLQuotedTableName2.result | 5 +
tajo-core/src/test/resources/yarn-site.xml | 25 +
tajo-core/src/test/tpch/customer.tbl | 5 +
tajo-core/src/test/tpch/empty_orders.tbl | 0
tajo-core/src/test/tpch/lineitem.tbl | 5 +
tajo-core/src/test/tpch/nation.tbl | 25 +
tajo-core/src/test/tpch/orders.tbl | 3 +
tajo-core/src/test/tpch/part.tbl | 3 +
tajo-core/src/test/tpch/partsupp.tbl | 3 +
tajo-core/src/test/tpch/region.tbl | 5 +
tajo-core/src/test/tpch/supplier.tbl | 3 +
.../benchmark/simple/groupby1.sql | 6 -
.../benchmark/simple/groupby2.sql | 6 -
.../benchmark/simple/selection1.sql | 5 -
.../benchmark/simple/selection2.sql | 5 -
.../benchmark/simple/selection3.sql | 7 -
.../benchmark/tpch/customer.schema | 9 -
.../benchmark/tpch/lineitem.schema | 19 -
.../benchmark/tpch/nation.schema | 6 -
.../benchmark/tpch/orders.schema | 11 -
.../benchmark/tpch/part.schema | 11 -
.../benchmark/tpch/partsupp.schema | 8 -
.../tajo-core-backend/benchmark/tpch/q1.sql | 21 -
.../tajo-core-backend/benchmark/tpch/q10.sql | 31 -
.../tajo-core-backend/benchmark/tpch/q11.sql | 27 -
.../tajo-core-backend/benchmark/tpch/q12.sql | 24 -
.../tajo-core-backend/benchmark/tpch/q13.sql | 18 -
.../tajo-core-backend/benchmark/tpch/q14.sql | 13 -
.../tajo-core-backend/benchmark/tpch/q15.sql | 32 -
.../tajo-core-backend/benchmark/tpch/q16.sql | 30 -
.../tajo-core-backend/benchmark/tpch/q17.sql | 17 -
.../tajo-core-backend/benchmark/tpch/q18.sql | 33 -
.../tajo-core-backend/benchmark/tpch/q19.sql | 35 -
.../tajo-core-backend/benchmark/tpch/q2.sql | 38 -
.../tajo-core-backend/benchmark/tpch/q20.sql | 36 -
.../tajo-core-backend/benchmark/tpch/q21.sql | 39 -
.../tajo-core-backend/benchmark/tpch/q22.sql | 36 -
.../tajo-core-backend/benchmark/tpch/q3.sql | 22 -
.../tajo-core-backend/benchmark/tpch/q4.sql | 21 -
.../tajo-core-backend/benchmark/tpch/q5.sql | 24 -
.../tajo-core-backend/benchmark/tpch/q6.sql | 10 -
.../tajo-core-backend/benchmark/tpch/q7.sql | 38 -
.../tajo-core-backend/benchmark/tpch/q8.sql | 37 -
.../tajo-core-backend/benchmark/tpch/q9.sql | 31 -
.../benchmark/tpch/region.schema | 5 -
.../benchmark/tpch/supplier.schema | 9 -
tajo-core/tajo-core-backend/pom.xml | 683 --
.../apache/tajo/engine/parser/HiveQLLexer.g4 | 390 -
.../apache/tajo/engine/parser/HiveQLParser.g4 | 2067 ----
.../org/apache/tajo/engine/parser/SQLLexer.g4 | 479 -
.../org/apache/tajo/engine/parser/SQLParser.g4 | 1398 ---
.../src/main/java/log4j.properties | 30 -
.../org/apache/tajo/benchmark/BenchmarkSet.java | 120 -
.../java/org/apache/tajo/benchmark/Driver.java | 46 -
.../org/apache/tajo/benchmark/SimpleQuery.java | 29 -
.../java/org/apache/tajo/benchmark/TPCH.java | 200 -
.../eval/AggregationFunctionCallEval.java | 92 -
.../tajo/engine/eval/AlgebraicException.java | 41 -
.../apache/tajo/engine/eval/AlgebraicUtil.java | 398 -
.../tajo/engine/eval/BasicEvalNodeVisitor.java | 341 -
.../tajo/engine/eval/BetweenPredicateEval.java | 219 -
.../org/apache/tajo/engine/eval/BinaryEval.java | 205 -
.../apache/tajo/engine/eval/CaseWhenEval.java | 208 -
.../org/apache/tajo/engine/eval/CastEval.java | 87 -
.../org/apache/tajo/engine/eval/ConstEval.java | 99 -
.../org/apache/tajo/engine/eval/EvalNode.java | 118 -
.../tajo/engine/eval/EvalNodeVisitor.java | 24 -
.../tajo/engine/eval/EvalNodeVisitor2.java | 71 -
.../tajo/engine/eval/EvalTreeFactory.java | 32 -
.../apache/tajo/engine/eval/EvalTreeUtil.java | 350 -
.../org/apache/tajo/engine/eval/EvalType.java | 83 -
.../org/apache/tajo/engine/eval/FieldEval.java | 114 -
.../apache/tajo/engine/eval/FunctionEval.java | 144 -
.../tajo/engine/eval/GeneralFunctionEval.java | 81 -
.../org/apache/tajo/engine/eval/InEval.java | 86 -
.../tajo/engine/eval/InvalidCastException.java | 36 -
.../tajo/engine/eval/InvalidEvalException.java | 36 -
.../org/apache/tajo/engine/eval/IsNullEval.java | 84 -
.../tajo/engine/eval/LikePredicateEval.java | 50 -
.../org/apache/tajo/engine/eval/NotEval.java | 92 -
.../tajo/engine/eval/PartialBinaryExpr.java | 70 -
.../engine/eval/PatternMatchPredicateEval.java | 82 -
.../tajo/engine/eval/RegexPredicateEval.java | 53 -
.../tajo/engine/eval/RowConstantEval.java | 79 -
.../org/apache/tajo/engine/eval/SignedEval.java | 99 -
.../engine/eval/SimilarToPredicateEval.java | 43 -
.../exception/AmbiguousFieldException.java | 30 -
.../exception/IllegalQueryStatusException.java | 38 -
.../engine/exception/InvalidQueryException.java | 35 -
.../engine/exception/NoSuchColumnException.java | 25 -
.../exception/RangeOverflowException.java | 28 -
.../tajo/engine/exception/VerifyException.java | 27 -
.../tajo/engine/function/AggFunction.java | 58 -
.../tajo/engine/function/FunctionContext.java | 22 -
.../tajo/engine/function/GeneralFunction.java | 56 -
.../engine/function/annotation/Description.java | 50 -
.../function/annotation/ParamOptionTypes.java | 29 -
.../engine/function/annotation/ParamTypes.java | 30 -
.../tajo/engine/function/builtin/AvgDouble.java | 97 -
.../tajo/engine/function/builtin/AvgFloat.java | 46 -
.../tajo/engine/function/builtin/AvgInt.java | 47 -
.../tajo/engine/function/builtin/AvgLong.java | 96 -
.../tajo/engine/function/builtin/Coalesce.java | 44 -
.../engine/function/builtin/CoalesceDouble.java | 43 -
.../engine/function/builtin/CoalesceLong.java | 44 -
.../engine/function/builtin/CoalesceString.java | 44 -
.../tajo/engine/function/builtin/CountRows.java | 84 -
.../engine/function/builtin/CountValue.java | 55 -
.../function/builtin/CountValueDistinct.java | 90 -
.../tajo/engine/function/builtin/Date.java | 62 -
.../tajo/engine/function/builtin/MaxDouble.java | 78 -
.../tajo/engine/function/builtin/MaxFloat.java | 76 -
.../tajo/engine/function/builtin/MaxInt.java | 77 -
.../tajo/engine/function/builtin/MaxLong.java | 77 -
.../tajo/engine/function/builtin/MaxString.java | 81 -
.../tajo/engine/function/builtin/MinDouble.java | 77 -
.../tajo/engine/function/builtin/MinFloat.java | 78 -
.../tajo/engine/function/builtin/MinInt.java | 77 -
.../tajo/engine/function/builtin/MinLong.java | 78 -
.../tajo/engine/function/builtin/MinString.java | 82 -
.../tajo/engine/function/builtin/RandomInt.java | 57 -
.../tajo/engine/function/builtin/Sleep.java | 52 -
.../tajo/engine/function/builtin/SumDouble.java | 82 -
.../function/builtin/SumDoubleDistinct.java | 98 -
.../tajo/engine/function/builtin/SumFloat.java | 80 -
.../function/builtin/SumFloatDistinct.java | 98 -
.../tajo/engine/function/builtin/SumInt.java | 82 -
.../engine/function/builtin/SumIntDistinct.java | 98 -
.../tajo/engine/function/builtin/SumLong.java | 82 -
.../function/builtin/SumLongDistinct.java | 98 -
.../tajo/engine/function/builtin/Today.java | 46 -
.../function/datetime/DatePartFromDate.java | 194 -
.../function/datetime/DatePartFromTime.java | 140 -
.../datetime/DatePartFromTimestamp.java | 259 -
.../datetime/DateTimePartFromUnixTimeStamp.java | 141 -
.../function/datetime/ToCharTimestamp.java | 79 -
.../engine/function/datetime/ToTimestamp.java | 55 -
.../function/geoip/GeoIPCountryInet4.java | 55 -
.../engine/function/geoip/GeoIPCountryText.java | 56 -
.../function/geoip/GeoIPInCountryInet4.java | 61 -
.../function/geoip/GeoIPInCountryText.java | 60 -
.../tajo/engine/function/math/AbsDouble.java | 61 -
.../tajo/engine/function/math/AbsFloat.java | 61 -
.../tajo/engine/function/math/AbsInt.java | 61 -
.../tajo/engine/function/math/AbsLong.java | 60 -
.../apache/tajo/engine/function/math/Acos.java | 61 -
.../apache/tajo/engine/function/math/Asin.java | 60 -
.../apache/tajo/engine/function/math/Atan.java | 60 -
.../apache/tajo/engine/function/math/Atan2.java | 62 -
.../apache/tajo/engine/function/math/Cbrt.java | 61 -
.../apache/tajo/engine/function/math/Ceil.java | 63 -
.../apache/tajo/engine/function/math/Cos.java | 60 -
.../tajo/engine/function/math/Degrees.java | 61 -
.../apache/tajo/engine/function/math/Div.java | 77 -
.../apache/tajo/engine/function/math/Exp.java | 61 -
.../apache/tajo/engine/function/math/Floor.java | 61 -
.../apache/tajo/engine/function/math/Mod.java | 77 -
.../apache/tajo/engine/function/math/Pi.java | 51 -
.../apache/tajo/engine/function/math/Pow.java | 78 -
.../tajo/engine/function/math/Radians.java | 62 -
.../apache/tajo/engine/function/math/Round.java | 71 -
.../apache/tajo/engine/function/math/Sign.java | 64 -
.../apache/tajo/engine/function/math/Sin.java | 60 -
.../apache/tajo/engine/function/math/Sqrt.java | 62 -
.../apache/tajo/engine/function/math/Tan.java | 60 -
.../tajo/engine/function/string/Ascii.java | 67 -
.../tajo/engine/function/string/BTrim.java | 77 -
.../tajo/engine/function/string/BitLength.java | 58 -
.../tajo/engine/function/string/CharLength.java | 59 -
.../apache/tajo/engine/function/string/Chr.java | 65 -
.../tajo/engine/function/string/Concat.java | 73 -
.../tajo/engine/function/string/Concat_ws.java | 78 -
.../tajo/engine/function/string/Decode.java | 91 -
.../tajo/engine/function/string/Digest.java | 87 -
.../tajo/engine/function/string/Encode.java | 93 -
.../tajo/engine/function/string/FindInSet.java | 116 -
.../function/string/HexStringConverter.java | 65 -
.../tajo/engine/function/string/InitCap.java | 60 -
.../tajo/engine/function/string/LTrim.java | 77 -
.../tajo/engine/function/string/Left.java | 84 -
.../tajo/engine/function/string/Length.java | 61 -
.../tajo/engine/function/string/Locate.java | 106 -
.../tajo/engine/function/string/Lower.java | 58 -
.../tajo/engine/function/string/Lpad.java | 90 -
.../apache/tajo/engine/function/string/Md5.java | 65 -
.../engine/function/string/OctetLength.java | 61 -
.../tajo/engine/function/string/QuoteIdent.java | 67 -
.../tajo/engine/function/string/RTrim.java | 76 -
.../engine/function/string/RegexpReplace.java | 115 -
.../tajo/engine/function/string/Repeat.java | 72 -
.../tajo/engine/function/string/Reverse.java | 58 -
.../tajo/engine/function/string/Right.java | 85 -
.../tajo/engine/function/string/Rpad.java | 90 -
.../tajo/engine/function/string/SplitPart.java | 73 -
.../tajo/engine/function/string/StrPos.java | 73 -
.../tajo/engine/function/string/StrPosb.java | 120 -
.../tajo/engine/function/string/Substr.java | 94 -
.../tajo/engine/function/string/ToBin.java | 65 -
.../tajo/engine/function/string/ToHex.java | 76 -
.../tajo/engine/function/string/Upper.java | 58 -
.../apache/tajo/engine/json/CoreGsonHelper.java | 90 -
.../tajo/engine/json/EvalNodeAdapter.java | 51 -
.../tajo/engine/json/LogicalNodeAdapter.java | 50 -
.../tajo/engine/parser/HiveQLAnalyzer.java | 1550 ---
.../apache/tajo/engine/parser/SQLAnalyzer.java | 1516 ---
.../tajo/engine/parser/SQLErrorListener.java | 38 -
.../tajo/engine/parser/SQLErrorStrategy.java | 66 -
.../tajo/engine/parser/SQLParseError.java | 107 -
.../tajo/engine/parser/SQLSyntaxError.java | 51 -
.../tajo/engine/planner/AlgebraVisitor.java | 110 -
.../engine/planner/AlterTablespaceNode.java | 103 -
.../tajo/engine/planner/BaseAlgebraVisitor.java | 739 --
.../engine/planner/BasicLogicalPlanVisitor.java | 319 -
.../planner/BroadcastJoinPlanVisitor.java | 86 -
.../planner/ExplainLogicalPlanVisitor.java | 236 -
.../tajo/engine/planner/ExprAnnotator.java | 631 -
.../apache/tajo/engine/planner/ExprFinder.java | 72 -
.../tajo/engine/planner/ExprNormalizer.java | 257 -
.../tajo/engine/planner/ExprsVerifier.java | 216 -
.../tajo/engine/planner/GroupElement.java | 64 -
.../tajo/engine/planner/LogicalOptimizer.java | 280 -
.../apache/tajo/engine/planner/LogicalPlan.java | 782 --
.../engine/planner/LogicalPlanPreprocessor.java | 442 -
.../engine/planner/LogicalPlanVerifier.java | 249 -
.../tajo/engine/planner/LogicalPlanVisitor.java | 91 -
.../tajo/engine/planner/LogicalPlanner.java | 1579 ---
.../tajo/engine/planner/NamedExprsManager.java | 369 -
.../tajo/engine/planner/PhysicalPlanner.java | 36 -
.../engine/planner/PhysicalPlannerImpl.java | 1057 --
.../planner/PhysicalPlanningException.java | 31 -
.../apache/tajo/engine/planner/PlanString.java | 119 -
.../apache/tajo/engine/planner/PlannerUtil.java | 762 --
.../tajo/engine/planner/PlanningException.java | 29 -
.../engine/planner/PreLogicalPlanVerifier.java | 274 -
.../apache/tajo/engine/planner/Projector.java | 51 -
.../engine/planner/RangePartitionAlgorithm.java | 187 -
.../engine/planner/SimpleAlgebraVisitor.java | 215 -
.../org/apache/tajo/engine/planner/Target.java | 129 -
.../engine/planner/UniformRangePartition.java | 451 -
.../tajo/engine/planner/VerificationState.java | 44 -
.../tajo/engine/planner/enforce/Enforcer.java | 262 -
.../tajo/engine/planner/global/DataChannel.java | 200 -
.../engine/planner/global/ExecutionBlock.java | 127 -
.../planner/global/ExecutionBlockCursor.java | 93 -
.../engine/planner/global/GlobalPlanner.java | 1187 --
.../tajo/engine/planner/global/MasterPlan.java | 268 -
.../engine/planner/graph/DirectedGraph.java | 64 -
.../planner/graph/DirectedGraphCursor.java | 65 -
.../planner/graph/DirectedGraphVisitor.java | 25 -
.../apache/tajo/engine/planner/graph/Graph.java | 45 -
.../planner/graph/SimpleDirectedGraph.java | 270 -
.../planner/graph/SimpleUndirectedGraph.java | 102 -
.../engine/planner/graph/UndirectedGraph.java | 30 -
.../engine/planner/logical/AlterTableNode.java | 134 -
.../tajo/engine/planner/logical/BinaryNode.java | 77 -
.../planner/logical/CreateDatabaseNode.java | 87 -
.../engine/planner/logical/CreateTableNode.java | 145 -
.../planner/logical/DropDatabaseNode.java | 85 -
.../engine/planner/logical/DropTableNode.java | 95 -
.../engine/planner/logical/EvalExprNode.java | 83 -
.../tajo/engine/planner/logical/ExceptNode.java | 45 -
.../engine/planner/logical/GroupbyNode.java | 198 -
.../tajo/engine/planner/logical/HavingNode.java | 67 -
.../engine/planner/logical/IndexScanNode.java | 122 -
.../tajo/engine/planner/logical/InsertNode.java | 182 -
.../engine/planner/logical/IntersectNode.java | 44 -
.../tajo/engine/planner/logical/JoinNode.java | 165 -
.../tajo/engine/planner/logical/LimitNode.java | 65 -
.../engine/planner/logical/LogicalNode.java | 128 -
.../planner/logical/LogicalNodeVisitor.java | 27 -
.../engine/planner/logical/LogicalRootNode.java | 41 -
.../tajo/engine/planner/logical/NodeType.java | 66 -
.../logical/PartitionedTableScanNode.java | 155 -
.../planner/logical/PersistentStoreNode.java | 90 -
.../engine/planner/logical/Projectable.java | 73 -
.../engine/planner/logical/ProjectionNode.java | 114 -
.../engine/planner/logical/RelationNode.java | 49 -
.../tajo/engine/planner/logical/ScanNode.java | 234 -
.../engine/planner/logical/SelectionNode.java | 69 -
.../planner/logical/ShuffleFileWriteNode.java | 104 -
.../tajo/engine/planner/logical/SortNode.java | 94 -
.../engine/planner/logical/StoreTableNode.java | 100 -
.../planner/logical/TableSubQueryNode.java | 181 -
.../tajo/engine/planner/logical/UnaryNode.java | 69 -
.../tajo/engine/planner/logical/UnionNode.java | 37 -
.../tajo/engine/planner/logical/join/Edge.java | 50 -
.../planner/logical/join/FoundJoinOrder.java | 47 -
.../join/GreedyHeuristicJoinOrderAlgorithm.java | 262 -
.../engine/planner/logical/join/JoinEdge.java | 76 -
.../engine/planner/logical/join/JoinGraph.java | 115 -
.../logical/join/JoinOrderAlgorithm.java | 46 -
.../planner/physical/AggregationExec.java | 69 -
.../engine/planner/physical/BNLJoinExec.java | 223 -
.../planner/physical/BSTIndexScanExec.java | 143 -
.../physical/BasicPhysicalExecutorVisitor.java | 265 -
.../planner/physical/BinaryPhysicalExec.java | 109 -
.../planner/physical/ColPartitionStoreExec.java | 100 -
.../engine/planner/physical/EvalExprExec.java | 66 -
.../planner/physical/ExternalSortExec.java | 782 --
.../planner/physical/HashAggregateExec.java | 115 -
.../HashBasedColPartitionStoreExec.java | 132 -
.../planner/physical/HashFullOuterJoinExec.java | 252 -
.../engine/planner/physical/HashJoinExec.java | 202 -
.../planner/physical/HashLeftAntiJoinExec.java | 109 -
.../planner/physical/HashLeftOuterJoinExec.java | 212 -
.../planner/physical/HashLeftSemiJoinExec.java | 107 -
.../planner/physical/HashPartitioner.java | 49 -
.../physical/HashShuffleFileWriteExec.java | 160 -
.../engine/planner/physical/HavingExec.java | 50 -
.../planner/physical/JoinTupleComparator.java | 87 -
.../tajo/engine/planner/physical/LimitExec.java | 55 -
.../engine/planner/physical/MemSortExec.java | 89 -
.../physical/MergeFullOuterJoinExec.java | 335 -
.../engine/planner/physical/MergeJoinExec.java | 193 -
.../engine/planner/physical/NLJoinExec.java | 104 -
.../planner/physical/NLLeftOuterJoinExec.java | 122 -
.../physical/PartitionMergeScanExec.java | 143 -
.../engine/planner/physical/Partitioner.java | 45 -
.../engine/planner/physical/PhysicalExec.java | 79 -
.../physical/PhysicalExecutorVisitor.java | 107 -
.../planner/physical/PhysicalPlanUtil.java | 39 -
.../physical/PhysicalPlanningException.java | 31 -
.../engine/planner/physical/ProjectionExec.java | 69 -
.../physical/RangeShuffleFileWriteExec.java | 131 -
.../physical/RightOuterMergeJoinExec.java | 346 -
.../engine/planner/physical/SelectionExec.java | 49 -
.../engine/planner/physical/SeqScanExec.java | 316 -
.../planner/physical/SortAggregateExec.java | 125 -
.../SortBasedColPartitionStoreExec.java | 149 -
.../tajo/engine/planner/physical/SortExec.java | 51 -
.../engine/planner/physical/StoreTableExec.java | 102 -
.../engine/planner/physical/TunnelExec.java | 42 -
.../planner/physical/UnaryPhysicalExec.java | 96 -
.../tajo/engine/planner/physical/UnionExec.java | 62 -
.../rewrite/BasicQueryRewriteEngine.java | 70 -
.../planner/rewrite/FilterPushDownRule.java | 323 -
.../rewrite/PartitionedTableRewriter.java | 373 -
.../planner/rewrite/ProjectionPushDownRule.java | 966 --
.../planner/rewrite/QueryRewriteEngine.java | 32 -
.../engine/planner/rewrite/RewriteRule.java | 56 -
.../apache/tajo/engine/query/QueryContext.java | 191 -
.../tajo/engine/query/QueryUnitRequest.java | 50 -
.../tajo/engine/query/QueryUnitRequestImpl.java | 328 -
.../apache/tajo/engine/utils/SchemaUtil.java | 72 -
.../apache/tajo/engine/utils/ThreadUtil.java | 149 -
.../apache/tajo/engine/utils/TupleCache.java | 122 -
.../apache/tajo/engine/utils/TupleCacheKey.java | 60 -
.../tajo/engine/utils/TupleCacheScanner.java | 109 -
.../org/apache/tajo/engine/utils/TupleUtil.java | 231 -
.../tajo/master/AbstractTaskScheduler.java | 56 -
.../org/apache/tajo/master/ContainerProxy.java | 81 -
.../DefaultFragmentScheduleAlgorithm.java | 247 -
.../tajo/master/DefaultTaskScheduler.java | 896 --
.../apache/tajo/master/FetchScheduleEvent.java | 40 -
.../org/apache/tajo/master/FragmentPair.java | 73 -
.../tajo/master/FragmentScheduleAlgorithm.java | 38 -
.../FragmentScheduleAlgorithmFactory.java | 68 -
.../org/apache/tajo/master/GlobalEngine.java | 738 --
.../master/GreedyFragmentScheduleAlgorithm.java | 421 -
.../apache/tajo/master/LazyTaskScheduler.java | 522 -
.../apache/tajo/master/ScheduledFetches.java | 47 -
.../apache/tajo/master/TajoAsyncDispatcher.java | 232 -
.../apache/tajo/master/TajoContainerProxy.java | 178 -
.../java/org/apache/tajo/master/TajoMaster.java | 579 -
.../tajo/master/TajoMasterClientService.java | 754 --
.../apache/tajo/master/TajoMasterService.java | 172 -
.../tajo/master/TaskRunnerGroupEvent.java | 51 -
.../apache/tajo/master/TaskRunnerLauncher.java | 25 -
.../tajo/master/TaskSchedulerContext.java | 68 -
.../tajo/master/TaskSchedulerFactory.java | 69 -
.../java/org/apache/tajo/master/TaskState.java | 23 -
.../apache/tajo/master/YarnContainerProxy.java | 414 -
.../tajo/master/YarnTaskRunnerLauncherImpl.java | 200 -
.../apache/tajo/master/cluster/ServerName.java | 123 -
.../master/event/ContainerAllocationEvent.java | 77 -
.../event/ContainerAllocatorEventType.java | 26 -
.../tajo/master/event/ContainerEvent.java | 37 -
.../master/event/FragmentScheduleEvent.java | 61 -
.../event/GrouppedContainerAllocatorEvent.java | 45 -
.../tajo/master/event/LocalTaskEvent.java | 45 -
.../tajo/master/event/LocalTaskEventType.java | 23 -
.../tajo/master/event/QueryCompletedEvent.java | 42 -
.../event/QueryDiagnosticsUpdateEvent.java | 34 -
.../apache/tajo/master/event/QueryEvent.java | 36 -
.../tajo/master/event/QueryEventType.java | 36 -
.../event/QueryMasterQueryCompletedEvent.java | 39 -
.../tajo/master/event/QueryStartEvent.java | 74 -
.../tajo/master/event/QuerySubQueryEvent.java | 35 -
.../event/QueryUnitAttemptScheduleEvent.java | 87 -
.../master/event/SubQueryCompletedEvent.java | 42 -
.../event/SubQueryContainerAllocationEvent.java | 38 -
.../event/SubQueryDiagnosticsUpdateEvent.java | 34 -
.../apache/tajo/master/event/SubQueryEvent.java | 35 -
.../tajo/master/event/SubQueryEventType.java | 43 -
.../tajo/master/event/SubQueryTaskEvent.java | 43 -
.../master/event/TaskAttemptAssignedEvent.java | 48 -
.../tajo/master/event/TaskAttemptEvent.java | 36 -
.../tajo/master/event/TaskAttemptEventType.java | 54 -
.../master/event/TaskAttemptScheduleEvent.java | 37 -
.../event/TaskAttemptStatusUpdateEvent.java | 36 -
.../tajo/master/event/TaskCompletionEvent.java | 35 -
.../org/apache/tajo/master/event/TaskEvent.java | 35 -
.../apache/tajo/master/event/TaskEventType.java | 38 -
.../tajo/master/event/TaskFatalErrorEvent.java | 41 -
.../tajo/master/event/TaskRequestEvent.java | 59 -
.../tajo/master/event/TaskSchedulerEvent.java | 41 -
.../tajo/master/event/TaskTAttemptEvent.java | 34 -
.../master/metrics/CatalogMetricsGaugeSet.java | 56 -
.../metrics/WorkerResourceMetricsGaugeSet.java | 74 -
.../apache/tajo/master/querymaster/Query.java | 702 --
.../master/querymaster/QueryInProgress.java | 294 -
.../tajo/master/querymaster/QueryInfo.java | 125 -
.../tajo/master/querymaster/QueryJobEvent.java | 44 -
.../master/querymaster/QueryJobManager.java | 195 -
.../tajo/master/querymaster/QueryMaster.java | 504 -
.../querymaster/QueryMasterManagerService.java | 239 -
.../master/querymaster/QueryMasterRunner.java | 149 -
.../master/querymaster/QueryMasterTask.java | 556 -
.../tajo/master/querymaster/QueryUnit.java | 658 -
.../master/querymaster/QueryUnitAttempt.java | 442 -
.../tajo/master/querymaster/Repartitioner.java | 653 -
.../tajo/master/querymaster/SubQuery.java | 1125 --
.../tajo/master/querymaster/SubQueryState.java | 30 -
.../apache/tajo/master/rm/TajoRMContext.java | 84 -
.../tajo/master/rm/TajoResourceTracker.java | 253 -
.../tajo/master/rm/TajoWorkerContainer.java | 100 -
.../tajo/master/rm/TajoWorkerContainerId.java | 93 -
.../master/rm/TajoWorkerResourceManager.java | 537 -
.../java/org/apache/tajo/master/rm/Worker.java | 296 -
.../org/apache/tajo/master/rm/WorkerEvent.java | 37 -
.../apache/tajo/master/rm/WorkerEventType.java | 30 -
.../tajo/master/rm/WorkerLivelinessMonitor.java | 56 -
.../tajo/master/rm/WorkerReconnectEvent.java | 35 -
.../apache/tajo/master/rm/WorkerResource.java | 235 -
.../tajo/master/rm/WorkerResourceManager.java | 110 -
.../org/apache/tajo/master/rm/WorkerState.java | 44 -
.../tajo/master/rm/WorkerStatusEvent.java | 54 -
.../master/rm/YarnRMContainerAllocator.java | 237 -
.../tajo/master/rm/YarnTajoResourceManager.java | 349 -
.../master/session/InvalidSessionException.java | 25 -
.../session/NoSuchSessionVariableException.java | 25 -
.../org/apache/tajo/master/session/Session.java | 124 -
.../tajo/master/session/SessionConstants.java | 23 -
.../tajo/master/session/SessionEvent.java | 34 -
.../tajo/master/session/SessionEventType.java | 24 -
.../session/SessionLivelinessMonitor.java | 53 -
.../tajo/master/session/SessionManager.java | 139 -
.../org/apache/tajo/net/CachedDNSResolver.java | 64 -
.../apache/tajo/util/ApplicationIdUtils.java | 44 -
.../java/org/apache/tajo/util/ClassUtil.java | 155 -
.../java/org/apache/tajo/util/GeoIPUtil.java | 46 -
.../java/org/apache/tajo/util/IndexUtil.java | 148 -
.../main/java/org/apache/tajo/util/JSPUtil.java | 209 -
.../util/metrics/GroupNameMetricsFilter.java | 43 -
.../tajo/util/metrics/LogEventGaugeSet.java | 64 -
.../tajo/util/metrics/MetricsFilterList.java | 43 -
.../tajo/util/metrics/RegexpMetricsFilter.java | 51 -
.../tajo/util/metrics/TajoLogEventCounter.java | 86 -
.../apache/tajo/util/metrics/TajoMetrics.java | 133 -
.../tajo/util/metrics/TajoSystemMetrics.java | 213 -
.../util/metrics/reporter/GangliaReporter.java | 258 -
.../reporter/MetricsConsoleReporter.java | 80 -
.../MetricsConsoleScheduledReporter.java | 32 -
.../reporter/MetricsFileScheduledReporter.java | 58 -
.../MetricsStreamScheduledReporter.java | 179 -
.../util/metrics/reporter/NullReporter.java | 31 -
.../metrics/reporter/TajoMetricsReporter.java | 232 -
.../reporter/TajoMetricsScheduledReporter.java | 206 -
.../java/org/apache/tajo/webapp/HttpServer.java | 447 -
.../tajo/webapp/QueryExecutorServlet.java | 376 -
.../apache/tajo/webapp/StaticHttpServer.java | 69 -
.../tajo/worker/AbstractResourceAllocator.java | 54 -
.../org/apache/tajo/worker/DeletionService.java | 115 -
.../java/org/apache/tajo/worker/Fetcher.java | 256 -
.../apache/tajo/worker/InterDataRetriever.java | 113 -
.../tajo/worker/PartitionRetrieverHandler.java | 44 -
.../tajo/worker/RangeRetrieverHandler.java | 163 -
.../apache/tajo/worker/ResourceAllocator.java | 29 -
.../org/apache/tajo/worker/TajoQueryEngine.java | 49 -
.../tajo/worker/TajoResourceAllocator.java | 339 -
.../java/org/apache/tajo/worker/TajoWorker.java | 583 -
.../tajo/worker/TajoWorkerClientService.java | 221 -
.../tajo/worker/TajoWorkerManagerService.java | 152 -
.../main/java/org/apache/tajo/worker/Task.java | 762 --
.../apache/tajo/worker/TaskAttemptContext.java | 270 -
.../org/apache/tajo/worker/TaskHistory.java | 198 -
.../java/org/apache/tajo/worker/TaskRunner.java | 431 -
.../apache/tajo/worker/TaskRunnerManager.java | 238 -
.../tajo/worker/WorkerHeartbeatService.java | 289 -
.../tajo/worker/YarnResourceAllocator.java | 117 -
.../FileAccessForbiddenException.java | 40 -
.../tajo/worker/dataserver/HttpDataServer.java | 87 -
.../dataserver/HttpDataServerHandler.java | 199 -
.../HttpDataServerPipelineFactory.java | 55 -
.../apache/tajo/worker/dataserver/HttpUtil.java | 69 -
.../retriever/AdvancedDataRetriever.java | 128 -
.../dataserver/retriever/DataRetriever.java | 29 -
.../retriever/DirectoryRetriever.java | 56 -
.../worker/dataserver/retriever/FileChunk.java | 51 -
.../dataserver/retriever/RetrieverHandler.java | 33 -
.../src/main/proto/InternalTypes.proto | 32 -
.../src/main/proto/QueryMasterProtocol.proto | 42 -
.../main/proto/ResourceTrackerProtocol.proto | 40 -
.../src/main/proto/TajoMasterProtocol.proto | 154 -
.../src/main/proto/TajoWorkerProtocol.proto | 258 -
.../src/main/resources/catalog-default.xml | 32 -
.../src/main/resources/log4j.properties | 28 -
.../src/main/resources/tajo-default.xml | 50 -
.../src/main/resources/tajo-metrics.properties | 75 -
.../webapps/admin/WEB-INF/jetty-web.xml | 23 -
.../resources/webapps/admin/WEB-INF/web.xml | 27 -
.../resources/webapps/admin/catalogview.jsp | 166 -
.../main/resources/webapps/admin/cluster.jsp | 216 -
.../src/main/resources/webapps/admin/conf.jsp | 56 -
.../src/main/resources/webapps/admin/env.jsp | 67 -
.../main/resources/webapps/admin/functions.jsp | 77 -
.../src/main/resources/webapps/admin/getCSV.jsp | 31 -
.../src/main/resources/webapps/admin/header.jsp | 32 -
.../src/main/resources/webapps/admin/index.jsp | 184 -
.../src/main/resources/webapps/admin/query.jsp | 137 -
.../resources/webapps/admin/query_executor.jsp | 315 -
.../src/main/resources/webapps/admin/thread.jsp | 45 -
.../resources/webapps/static/img/logo_tajo.gif | Bin 3025 -> 0 bytes
.../main/resources/webapps/static/img/on.jpg | Bin 636 -> 0 bytes
.../resources/webapps/static/img/tajo_logo.png | Bin 7592 -> 0 bytes
.../resources/webapps/static/img/tajochar.jpg | Bin 325871 -> 0 bytes
.../static/img/tajochar_catalog_small.jpg | Bin 13275 -> 0 bytes
.../webapps/static/img/tajochar_little.jpg | Bin 27712 -> 0 bytes
.../webapps/static/img/tajochar_middle.jpg | Bin 129938 -> 0 bytes
.../static/img/tajochar_queries_small.jpg | Bin 5184 -> 0 bytes
.../webapps/static/img/tajochar_small.jpg | Bin 65024 -> 0 bytes
.../webapps/static/img/tajochar_title.jpg | Bin 40249 -> 0 bytes
.../webapps/static/img/tajochar_title_small.jpg | Bin 10308 -> 0 bytes
.../static/img/tajochar_worker_small.jpg | Bin 13329 -> 0 bytes
.../webapps/static/js/jquery-ui.min.js | 5 -
.../main/resources/webapps/static/js/jquery.js | 2 -
.../static/js/jquery.jsPlumb-1.3.16-all-min.js | 1 -
.../static/js/jquery.jsPlumb-1.3.16-all.js | 10561 -----------------
.../main/resources/webapps/static/queryplan.css | 55 -
.../src/main/resources/webapps/static/style.css | 74 -
.../resources/webapps/worker/WEB-INF/web.xml | 27 -
.../src/main/resources/webapps/worker/conf.jsp | 55 -
.../src/main/resources/webapps/worker/env.jsp | 69 -
.../main/resources/webapps/worker/header.jsp | 37 -
.../src/main/resources/webapps/worker/index.jsp | 150 -
.../resources/webapps/worker/querydetail.jsp | 105 -
.../main/resources/webapps/worker/queryplan.jsp | 237 -
.../resources/webapps/worker/querytasks.jsp | 232 -
.../main/resources/webapps/worker/queryunit.jsp | 171 -
.../resources/webapps/worker/taskcontainers.jsp | 87 -
.../resources/webapps/worker/taskdetail.jsp | 127 -
.../src/main/resources/webapps/worker/tasks.jsp | 94 -
.../main/resources/webapps/worker/thread.jsp | 47 -
.../src/test/java/log4j.properties | 28 -
.../org/apache/tajo/BackendTestingUtil.java | 76 -
.../java/org/apache/tajo/IntegrationTest.java | 22 -
.../apache/tajo/LocalTajoTestingUtility.java | 136 -
.../org/apache/tajo/MiniTajoYarnCluster.java | 175 -
.../java/org/apache/tajo/QueryTestCaseBase.java | 539 -
.../org/apache/tajo/TajoTestingCluster.java | 630 -
.../org/apache/tajo/TestQueryIdFactory.java | 58 -
.../test/java/org/apache/tajo/TestTajoIds.java | 168 -
.../test/java/org/apache/tajo/TpchTestBase.java | 117 -
.../org/apache/tajo/benchmark/TestTPCH.java | 56 -
.../tajo/cli/TestExecExternalShellCommand.java | 46 -
.../org/apache/tajo/cli/TestHdfsCommand.java | 46 -
.../org/apache/tajo/cli/TestSimpleParser.java | 179 -
.../org/apache/tajo/client/TestDDLBuilder.java | 133 -
.../org/apache/tajo/client/TestTajoClient.java | 666 --
.../org/apache/tajo/cluster/TestServerName.java | 102 -
.../apache/tajo/engine/eval/ExprTestBase.java | 210 -
.../apache/tajo/engine/eval/TestEvalTree.java | 323 -
.../tajo/engine/eval/TestEvalTreeUtil.java | 359 -
.../apache/tajo/engine/eval/TestPredicates.java | 396 -
.../tajo/engine/eval/TestSQLDateTimeTypes.java | 53 -
.../tajo/engine/eval/TestSQLExpression.java | 206 -
.../tajo/engine/function/TestAggFunction.java | 64 -
.../engine/function/TestBuiltinFunctions.java | 123 -
.../function/TestConditionalExpressions.java | 82 -
.../engine/function/TestDateTimeFunctions.java | 253 -
.../engine/function/TestGeneralFunction.java | 49 -
.../tajo/engine/function/TestMathFunctions.java | 428 -
.../function/TestPatternMatchingPredicates.java | 140 -
.../TestStringOperatorsAndFunctions.java | 610 -
.../tajo/engine/parser/TestHiveQLAnalyzer.java | 271 -
.../tajo/engine/parser/TestSQLAnalyzer.java | 473 -
.../tajo/engine/planner/TestLogicalNode.java | 74 -
.../engine/planner/TestLogicalOptimizer.java | 263 -
.../tajo/engine/planner/TestLogicalPlan.java | 125 -
.../tajo/engine/planner/TestLogicalPlanner.java | 1136 --
.../tajo/engine/planner/TestPlannerUtil.java | 321 -
.../engine/planner/TestSimpleDirectedGraph.java | 79 -
.../planner/TestSimpleUndirectedGraph.java | 96 -
.../planner/TestUniformRangePartition.java | 442 -
.../planner/global/TestBroadcastJoinPlan.java | 400 -
.../engine/planner/global/TestMasterPlan.java | 53 -
.../planner/physical/TestBNLJoinExec.java | 217 -
.../planner/physical/TestBSTIndexExec.java | 210 -
.../planner/physical/TestExternalSortExec.java | 184 -
.../physical/TestFullOuterHashJoinExec.java | 403 -
.../physical/TestFullOuterMergeJoinExec.java | 536 -
.../planner/physical/TestHashAntiJoinExec.java | 209 -
.../planner/physical/TestHashJoinExec.java | 275 -
.../planner/physical/TestHashPartitioner.java | 84 -
.../planner/physical/TestHashSemiJoinExec.java | 214 -
.../physical/TestLeftOuterHashJoinExec.java | 463 -
.../physical/TestLeftOuterNLJoinExec.java | 474 -
.../planner/physical/TestMergeJoinExec.java | 193 -
.../engine/planner/physical/TestNLJoinExec.java | 209 -
.../planner/physical/TestPhysicalPlanner.java | 1023 --
.../physical/TestProgressExternalSortExec.java | 233 -
.../physical/TestRightOuterHashJoinExec.java | 350 -
.../physical/TestRightOuterMergeJoinExec.java | 520 -
.../engine/planner/physical/TestSortExec.java | 166 -
.../tajo/engine/query/TestAlterTable.java | 52 -
.../tajo/engine/query/TestAlterTablespace.java | 63 -
.../apache/tajo/engine/query/TestCTASQuery.java | 239 -
.../tajo/engine/query/TestCaseByCases.java | 70 -
.../tajo/engine/query/TestCreateDatabase.java | 75 -
.../tajo/engine/query/TestCreateTable.java | 360 -
.../apache/tajo/engine/query/TestDropTable.java | 38 -
.../tajo/engine/query/TestGroupByQuery.java | 246 -
.../tajo/engine/query/TestInsertQuery.java | 262 -
.../tajo/engine/query/TestJoinBroadcast.java | 377 -
.../query/TestJoinOnPartitionedTables.java | 56 -
.../apache/tajo/engine/query/TestJoinQuery.java | 325 -
.../apache/tajo/engine/query/TestNetTypes.java | 102 -
.../tajo/engine/query/TestNullValues.java | 162 -
.../tajo/engine/query/TestSelectQuery.java | 303 -
.../apache/tajo/engine/query/TestSortQuery.java | 146 -
.../tajo/engine/query/TestTablePartitions.java | 439 -
.../tajo/engine/query/TestTableSubQuery.java | 60 -
.../tajo/engine/query/TestUnionQuery.java | 141 -
.../apache/tajo/engine/util/TestTupleCache.java | 89 -
.../apache/tajo/engine/util/TestTupleUtil.java | 171 -
.../org/apache/tajo/jdbc/TestResultSet.java | 127 -
.../tajo/jdbc/TestTajoDatabaseMetaData.java | 355 -
.../java/org/apache/tajo/jdbc/TestTajoJdbc.java | 386 -
.../tajo/master/TestExecutionBlockCursor.java | 123 -
.../apache/tajo/master/TestGlobalPlanner.java | 205 -
.../apache/tajo/master/TestRepartitioner.java | 77 -
.../querymaster/TestQueryUnitStatusUpdate.java | 175 -
.../tajo/master/rm/TestTajoResourceManager.java | 378 -
.../apache/tajo/storage/TestFileFragment.java | 93 -
.../org/apache/tajo/storage/TestRowFile.java | 145 -
.../java/org/apache/tajo/util/TestJSPUtil.java | 84 -
.../tajo/util/metrics/TestMetricsFilter.java | 52 -
.../tajo/util/metrics/TestSystemMetrics.java | 133 -
.../org/apache/tajo/worker/TestFetcher.java | 94 -
.../tajo/worker/TestRangeRetrieverHandler.java | 373 -
.../worker/dataserver/TestHttpDataServer.java | 172 -
.../tajo/worker/dataserver/TestHttpUtil.java | 49 -
.../resources/dataset/TestAlterTable/table1.tbl | 3 -
.../dataset/TestCreateTable/table1/table1.tbl | 3 -
.../dataset/TestCreateTable/table2/table2.tbl | 3 -
.../resources/dataset/TestDropTable/table1.tbl | 3 -
.../customer_large/customer.tbl | 100 -
.../lineitem_large/lineitem.tbl | 97 -
.../dataset/TestJoinQuery/table1/table1.tbl | 5 -
.../dataset/TestJoinQuery/table2/table2.tbl | 4 -
.../dataset/TestNetTypes/table1/table1.tbl | 5 -
.../dataset/TestNetTypes/table2/table2.tbl | 5 -
.../dataset/TestSortQuery/table1/table1.tbl | 5 -
.../dataset/TestSortQuery/table2/table2.tbl | 24 -
.../src/test/resources/log4j.properties | 28 -
.../org/apache/tajo/client/TestTajoDump.java | 44 -
.../alter_table_add_new_column_ddl.sql | 1 -
.../alter_table_rename_column_ddl.sql | 1 -
.../alter_table_rename_table_ddl.sql | 1 -
.../queries/TestAlterTable/table1_ddl.sql | 1 -
.../TestBuiltinFunctions/testAvgDouble.sql | 1 -
.../queries/TestBuiltinFunctions/testAvgInt.sql | 1 -
.../TestBuiltinFunctions/testAvgLong.sql | 1 -
.../queries/TestBuiltinFunctions/testCount.sql | 1 -
.../TestBuiltinFunctions/testMaxLong.sql | 1 -
.../TestBuiltinFunctions/testMaxString.sql | 1 -
.../TestBuiltinFunctions/testMinLong.sql | 1 -
.../TestBuiltinFunctions/testMinString.sql | 1 -
.../queries/TestBuiltinFunctions/testRandom.sql | 1 -
.../TestBuiltinFunctions/testSplitPart.sql | 1 -
.../testSplitPartByString.sql | 1 -
.../testSplitPartNested.sql | 1 -
.../queries/TestCTASQuery/CtasWithGroupby.sql | 2 -
.../queries/TestCTASQuery/CtasWithLimit.sql | 13 -
.../TestCTASQuery/CtasWithManagedTable.sql | 12 -
.../queries/TestCTASQuery/CtasWithOptions.sql | 13 -
.../queries/TestCTASQuery/CtasWithOrderby.sql | 11 -
.../queries/TestCTASQuery/CtasWithStoreType.sql | 12 -
.../queries/TestCTASQuery/CtasWithUnion.sql | 35 -
.../resources/queries/TestCTASQuery/check1.sql | 1 -
.../resources/queries/TestCTASQuery/check2.sql | 1 -
.../testCtasWithColumnedPartition.sql | 2 -
.../TestCTASQuery/testCtasWithGroupby.sql | 1 -
.../queries/TestCTASQuery/testCtasWithLimit.sql | 1 -
.../TestCTASQuery/testCtasWithOptions.sql | 1 -
.../TestCTASQuery/testCtasWithOrderby.sql | 1 -
.../TestCTASQuery/testCtasWithStoreType.sql | 1 -
.../queries/TestCTASQuery/testCtasWithUnion.sql | 1 -
.../testCtasWithoutTableDefinition.sql | 2 -
.../queries/TestCaseByCases/testTAJO415Case.sql | 36 -
.../queries/TestCaseByCases/testTAJO418Case.sql | 29 -
.../queries/TestCaseByCases/testTAJO619Case.sql | 4 -
.../queries/TestCaseByCases/testTAJO718Case.sql | 10 -
.../queries/TestCaseByCases/testTAJO739Case.sql | 5 -
.../create_table_various_types.sql | 50 -
.../create_table_various_types_for_hcatalog.sql | 50 -
.../quoted_identifier_mixed_chars_1.sql | 1 -
.../quoted_identifier_mixed_chars_2.sql | 1 -
.../quoted_identifier_mixed_chars_3.sql | 22 -
.../quoted_identifier_mixed_chars_ddl_1.sql | 1 -
.../quoted_identifier_mixed_chars_ddl_2.sql | 1 -
.../quoted_identifier_non_ascii_1.sql | 1 -
.../quoted_identifier_non_ascii_2.sql | 1 -
.../quoted_identifier_non_ascii_3.sql | 1 -
.../quoted_identifier_non_ascii_ddl.sql | 1 -
.../queries/TestCreateTable/table1_ddl.sql | 1 -
.../queries/TestDropTable/drop_table_ddl.sql | 1 -
.../queries/TestDropTable/table1_ddl.sql | 1 -
.../TestGroupByQuery/testComplexParameter.sql | 1 -
.../TestGroupByQuery/testComplexParameter2.sql | 1 -
.../testComplexParameterWithSubQuery.sql | 6 -
.../testDistinctAggregation1.sql | 1 -
.../testDistinctAggregation2.sql | 1 -
.../testDistinctAggregation3.sql | 1 -
.../testDistinctAggregation4.sql | 1 -
.../testDistinctAggregation5.sql | 1 -
.../testDistinctAggregation6.sql | 9 -
.../testDistinctAggregationWithHaving1.sql | 1 -
.../testDistinctAggregationWithUnion1.sql | 21 -
.../queries/TestGroupByQuery/testGroupBy.sql | 1 -
.../queries/TestGroupByQuery/testGroupBy2.sql | 1 -
.../queries/TestGroupByQuery/testGroupBy3.sql | 1 -
.../queries/TestGroupByQuery/testGroupBy4.sql | 9 -
.../queries/TestGroupByQuery/testGroupBy5.sql | 1 -
.../TestGroupByQuery/testGroupByNested1.sql | 8 -
.../TestGroupByQuery/testGroupByNested2.sql | 10 -
.../testGroupByWithConstantKeys1.sql | 1 -
.../testGroupByWithExpressionKeys1.sql | 1 -
.../testGroupByWithExpressionKeys2.sql | 1 -
.../testGroupByWithSameExprs1.sql | 6 -
.../testGroupByWithSameExprs2.sql | 6 -
.../testHavingWithAggFunction.sql | 1 -
.../testHavingWithNamedTarget.sql | 1 -
.../create_customer_large_ddl.sql | 7 -
.../create_lineitem_large_ddl.sql | 7 -
.../queries/TestJoinBroadcast/oj_table1_ddl.sql | 6 -
.../queries/TestJoinBroadcast/oj_table2_ddl.sql | 6 -
.../testBroadcastBasicJoin.sql | 11 -
.../TestJoinBroadcast/testBroadcastSubquery.sql | 11 -
.../testBroadcastSubquery2.sql | 19 -
.../testBroadcastTwoPartJoin.sql | 15 -
.../queries/TestJoinBroadcast/testCrossJoin.sql | 1 -
.../testCrossJoinAndCaseWhen.sql | 18 -
.../testCrossJoinWithAsterisk1.sql | 1 -
.../testCrossJoinWithAsterisk2.sql | 1 -
.../testCrossJoinWithAsterisk3.sql | 1 -
.../testCrossJoinWithAsterisk4.sql | 1 -
.../testCrossJoinWithEmptyTable1.sql | 8 -
.../TestJoinBroadcast/testFullOuterJoin1.sql | 8 -
.../testFullOuterJoinWithEmptyTable1.sql | 8 -
.../testInnerJoinWithEmptyTable.sql | 8 -
.../testJoinCoReferredEvals1.sql | 11 -
.../testJoinCoReferredEvalsWithSameExprs1.sql | 14 -
.../testJoinCoReferredEvalsWithSameExprs2.sql | 22 -
.../testJoinOnMultipleDatabases.sql | 25 -
.../TestJoinBroadcast/testLeftOuterJoin1.sql | 9 -
.../testLeftOuterJoinWithConstantExpr1.sql | 9 -
.../testLeftOuterJoinWithConstantExpr2.sql | 9 -
.../testLeftOuterJoinWithConstantExpr3.sql | 17 -
.../testLeftOuterJoinWithEmptyTable1.sql | 9 -
.../testLeftOuterJoinWithEmptyTable2.sql | 9 -
.../testLeftOuterJoinWithEmptyTable3.sql | 14 -
.../testLeftOuterJoinWithEmptyTable4.sql | 17 -
.../testOuterJoinAndCaseWhen1.sql | 12 -
.../TestJoinBroadcast/testRightOuterJoin1.sql | 8 -
.../testRightOuterJoinWithEmptyTable1.sql | 8 -
.../TestJoinBroadcast/testTPCHQ2Join.sql | 25 -
.../TestJoinBroadcast/testWhereClauseJoin1.sql | 10 -
.../TestJoinBroadcast/testWhereClauseJoin2.sql | 8 -
.../TestJoinBroadcast/testWhereClauseJoin3.sql | 9 -
.../TestJoinBroadcast/testWhereClauseJoin4.sql | 8 -
.../TestJoinBroadcast/testWhereClauseJoin5.sql | 15 -
.../TestJoinBroadcast/testWhereClauseJoin6.sql | 19 -
.../customer_ddl.sql | 9 -
.../insert_into_customer.sql | 11 -
.../selfJoinOfPartitionedTable.sql | 9 -
.../testNoProjectionJoinQual.sql | 1 -
.../testPartialFilterPushDown.sql | 9 -
.../testPartitionTableJoinSmallTable.sql | 11 -
.../queries/TestJoinQuery/oj_table1_ddl.sql | 6 -
.../queries/TestJoinQuery/oj_table2_ddl.sql | 6 -
.../queries/TestJoinQuery/testCrossJoin.sql | 1 -
.../TestJoinQuery/testCrossJoinAndCaseWhen.sql | 18 -
.../testCrossJoinWithAsterisk1.sql | 1 -
.../testCrossJoinWithAsterisk2.sql | 1 -
.../testCrossJoinWithAsterisk3.sql | 1 -
.../testCrossJoinWithAsterisk4.sql | 1 -
.../testCrossJoinWithEmptyTable1.sql | 8 -
.../TestJoinQuery/testFullOuterJoin1.sql | 8 -
.../testFullOuterJoinWithEmptyTable1.sql | 8 -
.../testInnerJoinWithEmptyTable.sql | 8 -
.../TestJoinQuery/testJoinCoReferredEvals1.sql | 11 -
.../testJoinCoReferredEvalsWithSameExprs1.sql | 14 -
.../testJoinCoReferredEvalsWithSameExprs2.sql | 22 -
.../testJoinOnMultipleDatabases.sql | 25 -
.../TestJoinQuery/testLeftOuterJoin1.sql | 9 -
.../testLeftOuterJoinWithConstantExpr1.sql | 9 -
.../testLeftOuterJoinWithConstantExpr2.sql | 9 -
.../testLeftOuterJoinWithConstantExpr3.sql | 17 -
.../testLeftOuterJoinWithEmptyTable1.sql | 9 -
.../testLeftOuterJoinWithEmptyTable2.sql | 9 -
.../testLeftOuterJoinWithEmptyTable3.sql | 14 -
.../testLeftOuterJoinWithEmptyTable4.sql | 17 -
.../TestJoinQuery/testOuterJoinAndCaseWhen1.sql | 12 -
.../TestJoinQuery/testRightOuterJoin1.sql | 8 -
.../testRightOuterJoinWithEmptyTable1.sql | 8 -
.../queries/TestJoinQuery/testTPCHQ2Join.sql | 25 -
.../TestJoinQuery/testWhereClauseJoin1.sql | 10 -
.../TestJoinQuery/testWhereClauseJoin2.sql | 8 -
.../TestJoinQuery/testWhereClauseJoin3.sql | 9 -
.../TestJoinQuery/testWhereClauseJoin4.sql | 8 -
.../TestJoinQuery/testWhereClauseJoin5.sql | 15 -
.../TestJoinQuery/testWhereClauseJoin6.sql | 19 -
.../queries/TestNetTypes/table1_ddl.sql | 4 -
.../queries/TestNetTypes/table2_ddl.sql | 4 -
.../queries/TestNetTypes/testGroupby.sql | 8 -
.../queries/TestNetTypes/testGroupby2.sql | 9 -
.../resources/queries/TestNetTypes/testJoin.sql | 1 -
.../queries/TestNetTypes/testSelect.sql | 1 -
.../resources/queries/TestNetTypes/testSort.sql | 1 -
.../queries/TestNetTypes/testSort2.sql | 1 -
.../queries/TestQueryUnitStatusUpdate/case1.sql | 1 -
.../queries/TestQueryUnitStatusUpdate/case2.sql | 5 -
.../queries/TestQueryUnitStatusUpdate/case3.sql | 11 -
.../queries/TestSelectQuery/testCaseWhen.sql | 11 -
.../TestSelectQuery/testCaseWhenWithoutElse.sql | 10 -
.../TestSelectQuery/testCreateAfterSelect.sql | 1 -
.../TestSelectQuery/testDatabaseRef1.sql | 1 -
.../TestSelectQuery/testDatabaseRef2.sql | 1 -
.../TestSelectQuery/testDatabaseRef3.sql | 1 -
.../TestSelectQuery/testExplainSelect.sql | 1 -
.../queries/TestSelectQuery/testInClause.sql | 1 -
.../queries/TestSelectQuery/testInStrClause.sql | 1 -
.../queries/TestSelectQuery/testLikeClause.sql | 1 -
.../queries/TestSelectQuery/testLimit.sql | 1 -
.../TestSelectQuery/testNonFromSelect1.sql | 1 -
.../queries/TestSelectQuery/testNotEqual.sql | 1 -
.../queries/TestSelectQuery/testNotInClause.sql | 1 -
.../TestSelectQuery/testNotInStrClause.sql | 1 -
.../TestSelectQuery/testRealValueCompare.sql | 1 -
.../queries/TestSelectQuery/testSelect.sql | 1 -
.../queries/TestSelectQuery/testSelect2.sql | 1 -
.../queries/TestSelectQuery/testSelect3.sql | 1 -
.../TestSelectQuery/testSelectAsterik.sql | 1 -
.../TestSelectQuery/testSelectAsterisk1.sql | 1 -
.../TestSelectQuery/testSelectAsterisk2.sql | 1 -
.../TestSelectQuery/testSelectAsterisk3.sql | 1 -
.../TestSelectQuery/testSelectAsterisk4.sql | 1 -
.../TestSelectQuery/testSelectAsterisk5.sql | 1 -
.../TestSelectQuery/testSelectColumnAlias1.sql | 1 -
.../TestSelectQuery/testSelectDistinct.sql | 7 -
...tSelectSameConstantsWithDifferentAliases.sql | 1 -
.../testSelectSameExprsWithDifferentAliases.sql | 1 -
.../queries/TestSelectQuery/testSimpleQuery.sql | 1 -
.../testSimpleQueryWithLimit.sql | 1 -
.../TestSelectQuery/testStringCompare.sql | 1 -
.../queries/TestSelectQuery/testWhereCond1.sql | 1 -
.../TestSelectQuery/testWhereCondWithAlias1.sql | 1 -
.../TestSelectQuery/testWhereCondWithAlias2.sql | 1 -
.../create_table_with_asc_desc_keys.sql | 1 -
.../create_table_with_date_ddl.sql | 10 -
.../queries/TestSortQuery/testAsterisk.sql | 1 -
.../queries/TestSortQuery/testSort.sql | 1 -
.../TestSortQuery/testSortAfterGroupby.sql | 1 -
.../testSortAfterGroupbyWithAlias.sql | 1 -
.../queries/TestSortQuery/testSortDesc.sql | 1 -
.../TestSortQuery/testSortWithAlias1.sql | 1 -
.../TestSortQuery/testSortWithAlias2.sql | 9 -
.../TestSortQuery/testSortWithAlias3.sql | 11 -
.../testSortWithAliasButOriginalName.sql | 1 -
.../TestSortQuery/testSortWithAscDescKeys.sql | 1 -
.../queries/TestSortQuery/testSortWithDate.sql | 1 -
.../queries/TestSortQuery/testSortWithExpr1.sql | 1 -
.../queries/TestSortQuery/testSortWithExpr2.sql | 1 -
.../queries/TestSortQuery/testTopK.sql | 1 -
.../queries/TestTPCH/testQ1OrderBy.sql | 12 -
.../queries/TestTPCH/testQ2FourJoins.sql | 18 -
.../queries/TestTPCH/testTPCH14Expr.sql | 12 -
.../queries/TestTablePartitions/case1.sql | 16 -
.../queries/TestTablePartitions/case2.sql | 31 -
.../queries/TestTablePartitions/case3.sql | 8 -
.../TestTableSubQuery/testGroupBySubQuery.sql | 1 -
.../TestTableSubQuery/testJoinSubQuery.sql | 5 -
.../TestTableSubQuery/testJoinSubQuery2.sql | 4 -
.../TestTableSubQuery/testTableSubquery1.sql | 1 -
.../queries/TestUnionQuery/testUnion1.sql | 19 -
.../queries/TestUnionQuery/testUnion10.sql | 158 -
.../queries/TestUnionQuery/testUnion2.sql | 18 -
.../queries/TestUnionQuery/testUnion3.sql | 19 -
.../queries/TestUnionQuery/testUnion4.sql | 16 -
.../queries/TestUnionQuery/testUnion5.sql | 20 -
.../queries/TestUnionQuery/testUnion6.sql | 15 -
.../queries/TestUnionQuery/testUnion7.sql | 18 -
.../queries/TestUnionQuery/testUnion8.sql | 24 -
.../queries/TestUnionQuery/testUnion9.sql | 29 -
.../testUnionWithSameAliasNames.sql | 25 -
.../resources/queries/default/asterisk_1.sql | 1 -
.../resources/queries/default/asterisk_2.sql | 1 -
.../resources/queries/default/asterisk_3.sql | 1 -
.../resources/queries/default/asterisk_4.sql | 1 -
.../queries/default/complex_union_1.sql | 29 -
.../queries/default/complex_union_2.sql | 35 -
.../create_partitioned_table_as_select.sql | 17 -
.../queries/default/create_table_1.hiveql | 1 -
.../queries/default/create_table_1.sql | 1 -
.../queries/default/create_table_10.sql | 1 -
.../queries/default/create_table_11.hiveql | 3 -
.../queries/default/create_table_11.sql | 3 -
.../queries/default/create_table_12.hiveql | 4 -
.../queries/default/create_table_12.sql | 3 -
.../queries/default/create_table_2.hiveql | 1 -
.../queries/default/create_table_2.sql | 1 -
.../queries/default/create_table_3.sql | 1 -
.../queries/default/create_table_4.sql | 1 -
.../queries/default/create_table_5.sql | 1 -
.../queries/default/create_table_6.sql | 1 -
.../queries/default/create_table_7.sql | 1 -
.../queries/default/create_table_8.sql | 48 -
.../queries/default/create_table_9.sql | 1 -
.../create_table_partition_by_column.sql | 4 -
.../create_table_partition_by_hash_1.sql | 3 -
.../create_table_partition_by_hash_2.sql | 7 -
.../default/create_table_partition_by_list.sql | 8 -
.../default/create_table_partition_by_range.sql | 9 -
.../resources/queries/default/drop_table.sql | 1 -
.../queries/default/exists_predicate_1.sql | 1 -
.../queries/default/exists_predicate_2.sql | 1 -
.../resources/queries/default/groupby_1.sql | 1 -
.../resources/queries/default/groupby_2.sql | 1 -
.../resources/queries/default/groupby_3.sql | 1 -
.../resources/queries/default/groupby_4.sql | 1 -
.../resources/queries/default/groupby_5.sql | 1 -
.../resources/queries/default/in_subquery_1.sql | 1 -
.../resources/queries/default/in_subquery_2.sql | 1 -
.../queries/default/insert_into_select_1.sql | 1 -
.../queries/default/insert_into_select_2.sql | 1 -
.../queries/default/insert_into_select_3.sql | 1 -
.../default/insert_overwrite_into_select_1.sql | 1 -
.../insert_overwrite_into_select_2.hiveql | 1 -
.../default/insert_overwrite_into_select_2.sql | 1 -
.../default/insert_overwrite_into_select_3.sql | 1 -
.../test/resources/queries/default/join_1.sql | 1 -
.../test/resources/queries/default/join_10.sql | 1 -
.../test/resources/queries/default/join_11.sql | 1 -
.../test/resources/queries/default/join_12.sql | 1 -
.../test/resources/queries/default/join_13.sql | 13 -
.../test/resources/queries/default/join_14.sql | 1 -
.../resources/queries/default/join_15.hiveql | 1 -
.../test/resources/queries/default/join_15.sql | 1 -
.../test/resources/queries/default/join_2.sql | 1 -
.../test/resources/queries/default/join_3.sql | 1 -
.../test/resources/queries/default/join_4.sql | 1 -
.../test/resources/queries/default/join_5.sql | 1 -
.../test/resources/queries/default/join_6.sql | 1 -
.../test/resources/queries/default/join_7.sql | 1 -
.../test/resources/queries/default/join_8.sql | 13 -
.../test/resources/queries/default/join_9.sql | 5 -
.../test/resources/queries/default/select_1.sql | 1 -
.../resources/queries/default/select_10.hiveql | 5 -
.../resources/queries/default/select_10.sql | 5 -
.../resources/queries/default/select_11.hiveql | 4 -
.../resources/queries/default/select_11.sql | 6 -
.../resources/queries/default/select_12.hiveql | 3 -
.../resources/queries/default/select_13.hiveql | 2 -
.../resources/queries/default/select_13.sql | 2 -
.../resources/queries/default/select_14.sql | 2 -
.../resources/queries/default/select_15.hiveql | 1 -
.../resources/queries/default/select_15.sql | 1 -
.../test/resources/queries/default/select_2.sql | 1 -
.../test/resources/queries/default/select_3.sql | 1 -
.../test/resources/queries/default/select_4.sql | 1 -
.../test/resources/queries/default/select_5.sql | 1 -
.../test/resources/queries/default/select_6.sql | 1 -
.../test/resources/queries/default/select_7.sql | 1 -
.../test/resources/queries/default/select_8.sql | 1 -
.../resources/queries/default/select_9.hiveql | 4 -
.../test/resources/queries/default/select_9.sql | 4 -
.../test/resources/queries/default/set_1.sql | 1 -
.../test/resources/queries/default/set_2.sql | 1 -
.../test/resources/queries/default/set_3.sql | 1 -
.../test/resources/queries/default/set_4.sql | 36 -
.../queries/default/table_subquery1.sql | 19 -
.../queries/default/table_subquery2.sql | 21 -
.../resources/queries/default/union_1.hiveql | 14 -
.../TestBuiltinFunctions/testAvgDouble.result | 5 -
.../TestBuiltinFunctions/testAvgInt.result | 3 -
.../TestBuiltinFunctions/testAvgLong.result | 3 -
.../TestBuiltinFunctions/testCount.result | 3 -
.../TestBuiltinFunctions/testMaxLong.result | 3 -
.../TestBuiltinFunctions/testMaxString.result | 3 -
.../TestBuiltinFunctions/testMinLong.result | 3 -
.../TestBuiltinFunctions/testMinString.result | 3 -
.../TestBuiltinFunctions/testSplitPart.result | 7 -
.../testSplitPartByString.result | 7 -
.../testSplitPartNested.result | 7 -
.../TestCTASQuery/testCtasWithGroupby.result | 7 -
.../TestCTASQuery/testCtasWithLimit.result | 5 -
.../TestCTASQuery/testCtasWithOptions.result | 5 -
.../TestCTASQuery/testCtasWithOrderby.result | 7 -
.../TestCTASQuery/testCtasWithStoreType.result | 5 -
.../TestCTASQuery/testCtasWithUnion.result | 8 -
.../TestCaseByCases/testTAJO415Case.result | 7 -
.../TestCaseByCases/testTAJO418Case.result | 3 -
.../TestCaseByCases/testTAJO619Case.result | 3 -
.../TestCaseByCases/testTAJO718Case.result | 5 -
.../TestCaseByCases/testTAJO739Case.result | 7 -
.../quoted_identifier_mixed_chars_1.result | 5 -
.../quoted_identifier_mixed_chars_2.result | 5 -
.../quoted_identifier_mixed_chars_3.result | 8 -
.../quoted_identifier_non_ascii_1.result | 5 -
.../quoted_identifier_non_ascii_2.result | 5 -
.../quoted_identifier_non_ascii_3.result | 5 -
.../testComplexParameter.result | 3 -
.../testComplexParameter2.result | 3 -
.../testComplexParameterWithSubQuery.result | 3 -
.../testDistinctAggregation1.result | 5 -
.../testDistinctAggregation2.result | 5 -
.../testDistinctAggregation3.result | 3 -
.../testDistinctAggregation4.result | 4 -
.../testDistinctAggregation5.result | 4 -
.../testDistinctAggregation6.result | 5 -
.../testDistinctAggregationWithHaving1.result | 3 -
.../testDistinctAggregationWithUnion1.result | 4 -
.../results/TestGroupByQuery/testGroupBy.result | 3 -
.../TestGroupByQuery/testGroupBy2.result | 4 -
.../TestGroupByQuery/testGroupBy3.result | 5 -
.../TestGroupByQuery/testGroupBy4.result | 5 -
.../TestGroupByQuery/testGroupBy5.result | 5 -
.../TestGroupByQuery/testGroupByNested1.result | 6 -
.../TestGroupByQuery/testGroupByNested2.result | 6 -
.../testGroupByWithExpressionKeys1.result | 5 -
.../testGroupByWithExpressionKeys2.result | 5 -
.../testGroupByWithSameExprs1.result | 6 -
.../testGroupByWithSameExprs2.result | 6 -
.../testHavingWithAggFunction.result | 4 -
.../testHavingWithNamedTarget.result | 5 -
.../testBroadcastBasicJoin.result | 99 -
.../testBroadcastSubquery.result | 15 -
.../testBroadcastSubquery2.result | 3 -
.../testBroadcastTwoPartJoin.result | 15 -
.../TestJoinBroadcast/testCrossJoin.result | 127 -
.../testCrossJoinAndCaseWhen.result | 27 -
.../testCrossJoinWithAsterisk1.result | 27 -
.../testCrossJoinWithAsterisk2.result | 27 -
.../testCrossJoinWithAsterisk3.result | 27 -
.../testCrossJoinWithAsterisk4.result | 27 -
.../testCrossJoinWithEmptyTable1.result | 2 -
.../TestJoinBroadcast/testFullOuterJoin1.result | 7 -
.../testFullOuterJoinWithEmptyTable1.result | 7 -
.../testInnerJoinWithEmptyTable.result | 2 -
.../testJoinCoReferredEvals1.result | 27 -
...testJoinCoReferredEvalsWithSameExprs1.result | 22 -
...testJoinCoReferredEvalsWithSameExprs2.result | 22 -
.../testJoinOnMultipleDatabases.result | 5 -
.../TestJoinBroadcast/testLeftOuterJoin1.result | 7 -
.../testLeftOuterJoinWithConstantExpr1.result | 7 -
.../testLeftOuterJoinWithConstantExpr2.result | 7 -
.../testLeftOuterJoinWithConstantExpr3.result | 7 -
.../testLeftOuterJoinWithEmptyTable1.result | 7 -
.../testLeftOuterJoinWithEmptyTable2.result | 7 -
.../testLeftOuterJoinWithEmptyTable3.result | 7 -
.../testLeftOuterJoinWithEmptyTable4.result | 4 -
.../testOuterJoinAndCaseWhen1.result | 7 -
.../testRightOuterJoin1.result | 7 -
.../testRightOuterJoinWithEmptyTable1.result | 7 -
.../TestJoinBroadcast/testTPCHQ2Join.result | 5 -
.../testWhereClauseJoin1.result | 27 -
.../testWhereClauseJoin2.result | 27 -
.../testWhereClauseJoin3.result | 27 -
.../testWhereClauseJoin4.result | 27 -
.../testWhereClauseJoin5.result | 5 -
.../selfJoinOfPartitionedTable.result | 7 -
.../testNoProjectionJoinQual.result | 3 -
.../testPartialFilterPushDown.result | 3 -
.../testPartitionTableJoinSmallTable.result | 7 -
.../results/TestJoinQuery/testCrossJoin.result | 127 -
.../testCrossJoinAndCaseWhen.result | 27 -
.../testCrossJoinWithAsterisk1.result | 27 -
.../testCrossJoinWithAsterisk2.result | 27 -
.../testCrossJoinWithAsterisk3.result | 27 -
.../testCrossJoinWithAsterisk4.result | 27 -
.../testCrossJoinWithEmptyTable1.result | 2 -
.../TestJoinQuery/testFullOuterJoin1.result | 7 -
.../testFullOuterJoinWithEmptyTable1.result | 7 -
.../testInnerJoinWithEmptyTable.result | 2 -
.../testJoinCoReferredEvals1.result | 27 -
...testJoinCoReferredEvalsWithSameExprs1.result | 22 -
...testJoinCoReferredEvalsWithSameExprs2.result | 22 -
.../testJoinOnMultipleDatabases.result | 5 -
.../TestJoinQuery/testLeftOuterJoin1.result | 7 -
.../testLeftOuterJoinWithConstantExpr1.result | 7 -
.../testLeftOuterJoinWithConstantExpr2.result | 7 -
.../testLeftOuterJoinWithConstantExpr3.result | 7 -
.../testLeftOuterJoinWithEmptyTable1.result | 7 -
.../testLeftOuterJoinWithEmptyTable2.result | 7 -
.../testLeftOuterJoinWithEmptyTable3.result | 7 -
.../testLeftOuterJoinWithEmptyTable4.result | 4 -
.../testOuterJoinAndCaseWhen1.result | 7 -
.../TestJoinQuery/testRightOuterJoin1.result | 7 -
.../testRightOuterJoinWithEmptyTable1.result | 7 -
.../results/TestJoinQuery/testTPCHQ2Join.result | 5 -
.../TestJoinQuery/testWhereClauseJoin1.result | 27 -
.../TestJoinQuery/testWhereClauseJoin2.result | 27 -
.../TestJoinQuery/testWhereClauseJoin3.result | 27 -
.../TestJoinQuery/testWhereClauseJoin4.result | 27 -
.../TestJoinQuery/testWhereClauseJoin5.result | 5 -
.../results/TestNetTypes/testGroupby.result | 7 -
.../results/TestNetTypes/testGroupby2.result | 5 -
.../results/TestNetTypes/testJoin.result | 6 -
.../results/TestNetTypes/testSelect.result | 7 -
.../results/TestNetTypes/testSort.result | 7 -
.../results/TestNetTypes/testSort2.result | 6 -
.../results/TestSelectQuery/testCaseWhen.result | 7 -
.../testCaseWhenWithoutElse.result | 7 -
.../TestSelectQuery/testDatabaseRef.result | 7 -
.../TestSelectQuery/testExplainSelect.result | 6 -
.../results/TestSelectQuery/testInClause.result | 5 -
.../TestSelectQuery/testInStrClause.result | 4 -
.../TestSelectQuery/testLikeClause.result | 9 -
.../results/TestSelectQuery/testLimit.result | 5 -
.../TestSelectQuery/testNonFromSelect1.result | 3 -
.../results/TestSelectQuery/testNotEqual.result | 5 -
.../TestSelectQuery/testNotInClause.result | 4 -
.../TestSelectQuery/testNotInStrClause.result | 4 -
.../TestSelectQuery/testRealValueCompare.result | 3 -
.../results/TestSelectQuery/testSelect.result | 7 -
.../results/TestSelectQuery/testSelect2.result | 7 -
.../results/TestSelectQuery/testSelect3.result | 7 -
.../TestSelectQuery/testSelectAsterisk1.result | 7 -
.../TestSelectQuery/testSelectAsterisk2.result | 3 -
.../TestSelectQuery/testSelectAsterisk3.result | 3 -
.../TestSelectQuery/testSelectAsterisk4.result | 7 -
.../TestSelectQuery/testSelectAsterisk5.result | 3 -
.../testSelectColumnAlias1.result | 7 -
.../TestSelectQuery/testSelectDistinct.result | 7 -
...lectSameConstantsWithDifferentAliases.result | 7 -
...stSelectSameExprsWithDifferentAliases.result | 7 -
.../TestSelectQuery/testSimpleQuery.result | 7 -
.../testSimpleQueryWithLimit.result | 5 -
.../TestSelectQuery/testStringCompare.result | 5 -
.../results/TestSelectQuery/testUnion1.result | 10 -
.../results/TestSelectQuery/testUnion2.result | 12 -
.../TestSelectQuery/testWhereCond1.result | 3 -
.../testWhereCondWithAlias1.result | 4 -
.../testWhereCondWithAlias2.result | 4 -
.../results/TestSortQuery/testAsterisk.result | 7 -
.../results/TestSortQuery/testSort.result | 7 -
.../TestSortQuery/testSortAfterGroupby.result | 5 -
.../testSortAfterGroupbyWithAlias.result | 5 -
.../results/TestSortQuery/testSortDesc.result | 7 -
.../TestSortQuery/testSortWithAlias1.result | 7 -
.../TestSortQuery/testSortWithAlias2.result | 5 -
.../TestSortQuery/testSortWithAlias3.result | 7 -
.../testSortWithAliasButOriginalName.result | 7 -
.../testSortWithAscDescKeys.result | 26 -
.../TestSortQuery/testSortWithDate.result | 7 -
.../TestSortQuery/testSortWithExpr1.result | 7 -
.../TestSortQuery/testSortWithExpr2.result | 7 -
.../results/TestSortQuery/testTopK.result | 5 -
.../results/TestTPCH/testQ1OrderBy.result | 4 -
.../results/TestTPCH/testQ2FourJoins.result | 3 -
.../results/TestTPCH/testTPCH14Expr.result | 3 -
.../results/TestTablePartitions/case1.result | 4 -
.../results/TestTablePartitions/case2.result | 6 -
.../results/TestTablePartitions/case3.result | 5 -
.../testGroupBySubQuery.result | 3 -
.../TestTableSubQuery/testJoinSubQuery.result | 4 -
.../TestTableSubQuery/testJoinSubQuery2.result | 4 -
.../TestTableSubQuery/testTableSubquery1.result | 7 -
.../TestTajoDatabaseMetaData/getTables1.result | 4 -
.../TestTajoDatabaseMetaData/getTables2.result | 4 -
.../results/TestTajoDump/testDump1.result | 17 -
.../results/TestUnionQuery/testUnion1.result | 10 -
.../results/TestUnionQuery/testUnion10.result | 22 -
.../results/TestUnionQuery/testUnion2.result | 12 -
.../results/TestUnionQuery/testUnion3.result | 4 -
.../results/TestUnionQuery/testUnion4.result | 3 -
.../results/TestUnionQuery/testUnion5.result | 3 -
.../results/TestUnionQuery/testUnion6.result | 3 -
.../results/TestUnionQuery/testUnion7.result | 12 -
.../results/TestUnionQuery/testUnion8.result | 3 -
.../results/TestUnionQuery/testUnion9.result | 7 -
.../testUnionWithSameAliasNames.result | 12 -
.../testBuildDDLForBaseTable.result | 5 -
.../testBuildDDLForExternalTable.result | 5 -
.../testBuildDDLQuotedTableName1.result | 5 -
.../testBuildDDLQuotedTableName2.result | 5 -
.../src/test/resources/yarn-site.xml | 25 -
.../src/test/tpch/customer.tbl | 5 -
.../src/test/tpch/empty_orders.tbl | 0
.../src/test/tpch/lineitem.tbl | 5 -
.../tajo-core-backend/src/test/tpch/nation.tbl | 25 -
.../tajo-core-backend/src/test/tpch/orders.tbl | 3 -
.../tajo-core-backend/src/test/tpch/part.tbl | 3 -
.../src/test/tpch/partsupp.tbl | 3 -
.../tajo-core-backend/src/test/tpch/region.tbl | 5 -
.../src/test/tpch/supplier.tbl | 3 -
tajo-core/tajo-core-pullserver/pom.xml | 156 -
.../pullserver/FadvisedFileRegionWrapper.java | 35 -
.../pullserver/listener/FileCloseListener.java | 40 -
.../pullserver/FadvisedFileRegionWrapper.java | 34 -
.../pullserver/listener/FileCloseListener.java | 42 -
.../pullserver/FadvisedFileRegionWrapper.java | 36 -
.../pullserver/listener/FileCloseListener.java | 42 -
.../FileAccessForbiddenException.java | 40 -
.../tajo/pullserver/HttpDataServerHandler.java | 245 -
.../HttpDataServerPipelineFactory.java | 56 -
.../org/apache/tajo/pullserver/HttpUtil.java | 69 -
.../tajo/pullserver/PullServerAuxService.java | 657 -
.../tajo/pullserver/TajoPullServerService.java | 648 -
.../retriever/AdvancedDataRetriever.java | 126 -
.../pullserver/retriever/DataRetriever.java | 29 -
.../retriever/DirectoryRetriever.java | 56 -
.../tajo/pullserver/retriever/FileChunk.java | 51 -
.../pullserver/retriever/RetrieverHandler.java | 33 -
.../java/org/apache/tajo/storage/Tuple.java | 70 -
tajo-dist/pom.xml | 2 +-
tajo-project/pom.xml | 15 +-
.../org/apache/tajo/storage/TestStorages.java | 5 +-
tajo-yarn-pullserver/pom.xml | 156 +
.../pullserver/FadvisedFileRegionWrapper.java | 35 +
.../pullserver/listener/FileCloseListener.java | 40 +
.../pullserver/FadvisedFileRegionWrapper.java | 34 +
.../pullserver/listener/FileCloseListener.java | 42 +
.../pullserver/FadvisedFileRegionWrapper.java | 36 +
.../pullserver/listener/FileCloseListener.java | 42 +
.../FileAccessForbiddenException.java | 40 +
.../tajo/pullserver/HttpDataServerHandler.java | 245 +
.../HttpDataServerPipelineFactory.java | 56 +
.../org/apache/tajo/pullserver/HttpUtil.java | 69 +
.../tajo/pullserver/PullServerAuxService.java | 656 +
.../tajo/pullserver/TajoPullServerService.java | 648 +
.../retriever/AdvancedDataRetriever.java | 126 +
.../pullserver/retriever/DataRetriever.java | 29 +
.../retriever/DirectoryRetriever.java | 56 +
.../tajo/pullserver/retriever/FileChunk.java | 51 +
.../pullserver/retriever/RetrieverHandler.java | 33 +
.../java/org/apache/tajo/storage/Tuple.java | 70 +
2438 files changed, 116240 insertions(+), 116437 deletions(-)
----------------------------------------------------------------------