Marcel Kornacker has uploaded a new patch set (#4). Change subject: MT: Planner for multi-threaded execution ......................................................................
MT: Planner for multi-threaded execution New classes: - ParallelPlanner: creates build plans, assigns plans to cohorts - JoinBuildSink: DataSink for plan fragments that materialize build sides - ids for plans, hash tables, plan fragments Tests: this adds a new test file section PARALLELPLANS and augments the tpc-h/-ds tests with those sections. In the interest of keeping this patch small I didn't augment other test files with that section yet (which will happen at a later date, to cover more corner cases). Change-Id: Ic3c34dd3f9190a131e6f03d901b4bfcd164a5174 --- M be/src/service/query-options.cc M be/src/service/query-options.h M common/thrift/DataSinks.thrift M common/thrift/Frontend.thrift M common/thrift/ImpalaInternalService.thrift M common/thrift/ImpalaService.thrift M common/thrift/Planner.thrift M common/thrift/Types.thrift M fe/src/main/java/com/cloudera/impala/analysis/FunctionCallExpr.java M fe/src/main/java/com/cloudera/impala/analysis/TupleDescriptor.java M fe/src/main/java/com/cloudera/impala/common/TreeNode.java A fe/src/main/java/com/cloudera/impala/planner/CohortId.java M fe/src/main/java/com/cloudera/impala/planner/DataSink.java M fe/src/main/java/com/cloudera/impala/planner/DistributedPlanner.java M fe/src/main/java/com/cloudera/impala/planner/ExchangeNode.java M fe/src/main/java/com/cloudera/impala/planner/HashJoinNode.java A fe/src/main/java/com/cloudera/impala/planner/JoinBuildSink.java M fe/src/main/java/com/cloudera/impala/planner/JoinNode.java A fe/src/main/java/com/cloudera/impala/planner/JoinTableId.java M fe/src/main/java/com/cloudera/impala/planner/NestedLoopJoinNode.java A fe/src/main/java/com/cloudera/impala/planner/ParallelPlanner.java M fe/src/main/java/com/cloudera/impala/planner/PlanFragment.java A fe/src/main/java/com/cloudera/impala/planner/PlanId.java M fe/src/main/java/com/cloudera/impala/planner/PlanNode.java M fe/src/main/java/com/cloudera/impala/planner/Planner.java M fe/src/main/java/com/cloudera/impala/service/Frontend.java M fe/src/test/java/com/cloudera/impala/planner/PlannerTestBase.java M fe/src/test/java/com/cloudera/impala/testutil/TestFileParser.java M testdata/workloads/functional-planner/queries/PlannerTest/tpcds-all.test M testdata/workloads/functional-planner/queries/PlannerTest/tpch-all.test 30 files changed, 4,755 insertions(+), 124 deletions(-) git pull ssh://gerrit.cloudera.org:29418/Impala refs/changes/46/2846/4 -- To view, visit http://gerrit.cloudera.org:8080/2846 To unsubscribe, visit http://gerrit.cloudera.org:8080/settings Gerrit-MessageType: newpatchset Gerrit-Change-Id: Ic3c34dd3f9190a131e6f03d901b4bfcd164a5174 Gerrit-PatchSet: 4 Gerrit-Project: Impala Gerrit-Branch: cdh5-trunk Gerrit-Owner: Marcel Kornacker <[email protected]> Gerrit-Reviewer: Alex Behm <[email protected]> Gerrit-Reviewer: Henry Robinson <[email protected]> Gerrit-Reviewer: Marcel Kornacker <[email protected]>
