@@ -1034,7 +1034,7 @@ impl AggregateExec {
10341034 . execution
10351035 . enable_migration_aggregate
10361036 {
1037- if self . should_use_ordered_partial_aggregate_stream ( context ) {
1037+ if self . should_use_ordered_partial_aggregate_stream ( ) {
10381038 return Ok ( StreamType :: OrderedPartialAggregate (
10391039 OrderedPartialAggregateStream :: new ( self , context, partition) ?,
10401040 ) ) ;
@@ -1046,7 +1046,7 @@ impl AggregateExec {
10461046 ) ?) ) ;
10471047 }
10481048
1049- if self . should_use_ordered_final_aggregate_stream ( context ) {
1049+ if self . should_use_ordered_final_aggregate_stream ( ) {
10501050 return Ok ( StreamType :: OrderedFinalAggregate (
10511051 OrderedFinalAggregateStream :: new ( self , context, partition) ?,
10521052 ) ) ;
@@ -1078,7 +1078,7 @@ impl AggregateExec {
10781078 && self . limit_options_supported_by_hash_stream ( )
10791079 }
10801080
1081- fn should_use_ordered_partial_aggregate_stream ( & self , context : & TaskContext ) -> bool {
1081+ fn should_use_ordered_partial_aggregate_stream ( & self ) -> bool {
10821082 self . mode == AggregateMode :: Partial
10831083 && self . input_order_mode != InputOrderMode :: Linear
10841084 && !self . group_by . is_true_no_grouping ( )
@@ -1101,7 +1101,7 @@ impl AggregateExec {
11011101 && self . group_by . is_single ( )
11021102 }
11031103
1104- fn should_use_ordered_final_aggregate_stream ( & self , context : & TaskContext ) -> bool {
1104+ fn should_use_ordered_final_aggregate_stream ( & self ) -> bool {
11051105 matches ! (
11061106 self . mode,
11071107 AggregateMode :: Final | AggregateMode :: FinalPartitioned
0 commit comments