File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed
catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical
core/src/main/java/org/apache/spark/sql/execution Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -1019,13 +1019,13 @@ case class Aggregate(
10191019}
10201020
10211021object Aggregate {
1022- def supportsAggregationBufferSchema (schema : StructType ): Boolean = {
1022+ def isAggregateBufferMutable (schema : StructType ): Boolean = {
10231023 schema.forall(f => UnsafeRow .isMutable(f.dataType))
10241024 }
10251025
10261026 def supportsHashAggregate (aggregateBufferAttributes : Seq [Attribute ]): Boolean = {
10271027 val aggregationBufferSchema = StructType .fromAttributes(aggregateBufferAttributes)
1028- supportsAggregationBufferSchema (aggregationBufferSchema)
1028+ isAggregateBufferMutable (aggregationBufferSchema)
10291029 }
10301030
10311031 def supportsObjectHashAggregate (aggregateExpressions : Seq [AggregateExpression ]): Boolean = {
Original file line number Diff line number Diff line change @@ -68,7 +68,7 @@ public final class UnsafeFixedWidthAggregationMap {
6868 * schema, false otherwise.
6969 */
7070 public static boolean supportsAggregationBufferSchema (StructType schema ) {
71- return Aggregate$ .MODULE$ .supportsAggregationBufferSchema (schema );
71+ return Aggregate$ .MODULE$ .isAggregateBufferMutable (schema );
7272 }
7373
7474 /**
You can’t perform that action at this time.
0 commit comments