Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/tajo into index_support
Project: http://git-wip-us.apache.org/repos/asf/tajo/repo Commit: http://git-wip-us.apache.org/repos/asf/tajo/commit/70de1b44 Tree: http://git-wip-us.apache.org/repos/asf/tajo/tree/70de1b44 Diff: http://git-wip-us.apache.org/repos/asf/tajo/diff/70de1b44 Branch: refs/heads/index_support Commit: 70de1b443c2dd85b4ec87267c33c409c520b5854 Parents: 6a798c0 514ed84 Author: Jihoon Son <[email protected]> Authored: Tue Nov 4 21:31:35 2014 +0900 Committer: Jihoon Son <[email protected]> Committed: Tue Nov 4 21:31:35 2014 +0900 ---------------------------------------------------------------------- .travis.yml | 2 +- CHANGES | 8 + .../org/apache/tajo/catalog/SchemaUtil.java | 103 ++++ .../org/apache/tajo/client/QueryClientImpl.java | 7 +- .../java/org/apache/tajo/datum/TextDatum.java | 6 +- .../java/org/apache/tajo/storage/Tuple.java | 12 +- .../java/org/apache/tajo/storage/VTuple.java | 55 +- .../org/apache/tajo/util/Deallocatable.java | 23 + .../main/java/org/apache/tajo/util/SizeOf.java | 159 +++++ .../org/apache/tajo/util/UnsafeComparer.java | 160 +++++ .../java/org/apache/tajo/util/UnsafeUtil.java | 115 ++++ .../engine/planner/PhysicalPlannerImpl.java | 5 +- .../tajo/engine/planner/global/DataChannel.java | 2 +- .../planner/physical/ExternalSortExec.java | 130 ++++- .../planner/physical/HashFullOuterJoinExec.java | 2 +- .../engine/planner/physical/HashJoinExec.java | 2 +- .../planner/physical/HashLeftOuterJoinExec.java | 2 +- .../engine/planner/physical/MergeJoinExec.java | 2 +- .../planner/physical/PhysicalPlanUtil.java | 9 +- .../physical/RangeShuffleFileWriteExec.java | 2 +- .../physical/RightOuterMergeJoinExec.java | 2 +- .../engine/planner/physical/SeqScanExec.java | 2 +- .../tajo/engine/planner/physical/SortExec.java | 7 +- .../engine/planner/physical/WindowAggExec.java | 5 +- .../tajo/worker/RangeRetrieverHandler.java | 6 +- .../main/java/org/apache/tajo/worker/Task.java | 3 +- .../org/apache/tajo/TajoTestingCluster.java | 16 + .../apache/tajo/engine/eval/ExprTestBase.java | 2 +- .../tajo/engine/planner/TestPlannerUtil.java | 4 +- .../planner/TestUniformRangePartition.java | 4 +- .../planner/physical/TestBSTIndexExec.java | 4 +- .../planner/physical/TestExternalSortExec.java | 2 +- .../planner/physical/TestPhysicalPlanner.java | 2 +- .../physical/TestProgressExternalSortExec.java | 2 +- .../apache/tajo/engine/util/TestTupleUtil.java | 2 +- .../tajo/worker/TestRangeRetrieverHandler.java | 4 +- .../org/apache/tajo/jdbc/MetaDataTuple.java | 17 +- .../tajo/plan/LogicalPlanPreprocessor.java | 2 +- .../org/apache/tajo/plan/LogicalPlanner.java | 2 +- .../GreedyHeuristicJoinOrderAlgorithm.java | 2 +- .../org/apache/tajo/plan/logical/ScanNode.java | 2 +- .../tajo/plan/logical/TableSubQueryNode.java | 2 +- .../rewrite/rules/ProjectionPushDownRule.java | 2 +- .../org/apache/tajo/plan/util/PlannerUtil.java | 1 + .../org/apache/tajo/plan/util/SchemaUtil.java | 88 --- .../tajo/storage/BaseTupleComparator.java | 206 +++++++ .../org/apache/tajo/storage/FrameTuple.java | 14 +- .../java/org/apache/tajo/storage/LazyTuple.java | 13 +- .../org/apache/tajo/storage/RowStoreUtil.java | 202 +++++-- .../apache/tajo/storage/TupleComparator.java | 159 +---- .../org/apache/tajo/storage/TupleRange.java | 2 +- .../apache/tajo/storage/index/IndexMethod.java | 1 + .../apache/tajo/storage/index/bst/BSTIndex.java | 10 +- .../org/apache/tajo/tuple/BaseTupleBuilder.java | 112 ++++ .../org/apache/tajo/tuple/RowBlockReader.java | 33 ++ .../org/apache/tajo/tuple/TupleBuilder.java | 26 + .../tajo/tuple/offheap/DirectBufTuple.java | 41 ++ .../tajo/tuple/offheap/FixedSizeLimitSpec.java | 32 + .../apache/tajo/tuple/offheap/HeapTuple.java | 269 +++++++++ .../tajo/tuple/offheap/OffHeapMemory.java | 102 ++++ .../tajo/tuple/offheap/OffHeapRowBlock.java | 176 ++++++ .../tuple/offheap/OffHeapRowBlockReader.java | 63 ++ .../tuple/offheap/OffHeapRowBlockUtils.java | 54 ++ .../tuple/offheap/OffHeapRowBlockWriter.java | 58 ++ .../tajo/tuple/offheap/OffHeapRowWriter.java | 232 ++++++++ .../tajo/tuple/offheap/ResizableLimitSpec.java | 142 +++++ .../apache/tajo/tuple/offheap/RowWriter.java | 73 +++ .../apache/tajo/tuple/offheap/UnSafeTuple.java | 308 ++++++++++ .../offheap/UnSafeTupleBytesComparator.java | 99 ++++ .../tajo/tuple/offheap/ZeroCopyTuple.java | 35 ++ tajo-storage/src/main/proto/IndexProtos.proto | 4 +- .../tajo/storage/TestTupleComparator.java | 2 +- .../apache/tajo/storage/index/TestBSTIndex.java | 20 +- .../index/TestSingleCSVFileBSTIndex.java | 4 +- .../apache/tajo/tuple/TestBaseTupleBuilder.java | 76 +++ .../tajo/tuple/offheap/TestHeapTuple.java | 45 ++ .../tajo/tuple/offheap/TestOffHeapRowBlock.java | 577 +++++++++++++++++++ .../tajo/tuple/offheap/TestResizableSpec.java | 59 ++ 78 files changed, 3814 insertions(+), 426 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tajo/blob/70de1b44/tajo-core/src/main/java/org/apache/tajo/engine/planner/PhysicalPlannerImpl.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tajo/blob/70de1b44/tajo-core/src/test/java/org/apache/tajo/engine/planner/physical/TestPhysicalPlanner.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tajo/blob/70de1b44/tajo-plan/src/main/java/org/apache/tajo/plan/LogicalPlanPreprocessor.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tajo/blob/70de1b44/tajo-plan/src/main/java/org/apache/tajo/plan/LogicalPlanner.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tajo/blob/70de1b44/tajo-plan/src/main/java/org/apache/tajo/plan/rewrite/rules/ProjectionPushDownRule.java ----------------------------------------------------------------------
