Skip to content

Commit dc09c5c

Browse files
[BugFix] Fix miss implemention in aggregate combined functions (backport #74169) (#74200)
Signed-off-by: stdpain <drfeng08@gmail.com> Co-authored-by: stdpain <34912776+stdpain@users.noreply.github.com>
1 parent 404d6c8 commit dc09c5c

3 files changed

Lines changed: 6 additions & 0 deletions

File tree

be/src/exprs/agg/agg_state_if.h

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -224,6 +224,8 @@ class AggStateIf final : public AggregateFunctionBatchHelper<AggStateIfState, Ag
224224

225225
std::string get_name() const override { return "agg_state_if"; }
226226

227+
bool support_nullable_immediate_input() const override { return _function->support_nullable_immediate_input(); }
228+
227229
private:
228230
const AggStateDesc _agg_state_desc;
229231
const AggregateFunction* _function;

be/src/exprs/agg/agg_state_merge.h

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -82,6 +82,8 @@ class AggStateMerge final : public AggregateFunctionBatchHelper<AggStateMergeSta
8282

8383
std::string get_name() const override { return "agg_state_merge"; }
8484

85+
bool support_nullable_immediate_input() const override { return _function->support_nullable_immediate_input(); }
86+
8587
private:
8688
const AggStateDesc _agg_state_desc;
8789
const AggregateFunction* _function;

be/src/exprs/agg/agg_state_union.h

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -74,6 +74,8 @@ class AggStateUnion final : public AggregateFunctionBatchHelper<AggStateUnionSta
7474
_function->serialize_to_column(ctx, state, to);
7575
}
7676

77+
bool support_nullable_immediate_input() const override { return _function->support_nullable_immediate_input(); }
78+
7779
std::string get_name() const override { return "agg_state_union"; }
7880

7981
private:

0 commit comments

Comments
 (0)