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

Decimal optimize branch #695 (#727)

Browse Source
This commit is contained in:
lide
2019-03-22 17:22:16 +08:00
committed by ZHAO Chun
parent e60b71da8c
commit c34b306b4f
114 changed files with 3236 additions and 66 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
be/src/exec/pre_aggregation_node.cpp
View File

@ -547,6 +547,10 @@ Status PreAggregationNode::update_agg_row(TupleRow* agg_row, TupleRow* probe_row
UpdateMinSlot<DecimalValue>(slot, value);
break;
case TYPE_DECIMALV2:
UpdateMinSlot<DecimalV2Value>(slot, value);
break;
default:
LOG(WARNING) << "invalid type: " << type_to_string(agg_expr->type());
return Status("unknown type");
@ -593,6 +597,10 @@ Status PreAggregationNode::update_agg_row(TupleRow* agg_row, TupleRow* probe_row
UpdateMaxSlot<DecimalValue>(slot, value);
break;
case TYPE_DECIMALV2:
UpdateMaxSlot<DecimalV2Value>(slot, value);
break;
default:
LOG(WARNING) << "invalid type: " << type_to_string(agg_expr->type());
return Status("unknown type");
@ -614,6 +622,10 @@ Status PreAggregationNode::update_agg_row(TupleRow* agg_row, TupleRow* probe_row
UpdateSumSlot<DecimalValue>(slot, value);
break;
case TYPE_DECIMALV2:
UpdateSumSlot<DecimalV2Value>(slot, value);
break;
default:
LOG(WARNING) << "invalid type: " << type_to_string(agg_expr->type());
return Status("Aggsum not valid.");