database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

Revert "[CodeStyle] Del obsolete code of partition_aggregation_node (#3154)" (#3160)

Browse Source 
This reverts commit dae013d797c1c2c9e54246d5ace4bdd90b297d43.
This commit is contained in:
lichaoyong
2020-03-20 14:47:25 +08:00
committed by GitHub
parent 5f004cb009
commit 2d3dbc2c42
10 changed files with 3886 additions and 2183 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
be/src/exec/exec_node.cpp
View File

@ -26,6 +26,7 @@
#include "exprs/expr_context.h"
#include "exec/aggregation_node.h"
#include "exec/partitioned_aggregation_node.h"
#include "exec/new_partitioned_aggregation_node.h"
#include "exec/csv_scan_node.h"
#include "exec/es_scan_node.h"
#include "exec/es_http_scan_node.h"
@ -382,6 +383,8 @@ Status ExecNode::create_node(RuntimeState* state, ObjectPool* pool, const TPlanN
case TPlanNodeType::AGGREGATION_NODE:
if (config::enable_partitioned_aggregation) {
*node = pool->add(new PartitionedAggregationNode(pool, tnode, descs));
} else if (config::enable_new_partitioned_aggregation) {
*node = pool->add(new NewPartitionedAggregationNode(pool, tnode, descs));
} else {
*node = pool->add(new AggregationNode(pool, tnode, descs));
}