diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/python/WindowInPandasEvaluatorFactory.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/python/WindowInPandasEvaluatorFactory.scala index c7a227c4755e5..364e94ab158e9 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/python/WindowInPandasEvaluatorFactory.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/python/WindowInPandasEvaluatorFactory.scala @@ -125,7 +125,7 @@ class WindowInPandasEvaluatorFactory( } class WindowInPandasPartitionEvaluator extends PartitionEvaluator[InternalRow, InternalRow] { - val conf: SQLConf = SQLConf.get + private val conf: SQLConf = SQLConf.get // Unwrap the expressions and factories from the map. private val expressionsWithFrameIndex = diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/window/WindowEvaluatorFactory.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/window/WindowEvaluatorFactory.scala index d3abb0a3a32e8..913f8762c7953 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/window/WindowEvaluatorFactory.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/window/WindowEvaluatorFactory.scala @@ -178,7 +178,7 @@ trait WindowEvaluatorFactoryBase { // Map the groups to a (unbound) expression and frame factory pair. var numExpressions = 0 - val timeZone = conf.sessionLocalTimeZone + val timeZone = SQLConf.get.sessionLocalTimeZone framedFunctions.toSeq.map { case (key, (expressions, functionSeq)) => val ordinal = numExpressions @@ -303,13 +303,13 @@ class WindowEvaluatorFactory( } class WindowPartitionEvaluator extends PartitionEvaluator[InternalRow, InternalRow] { - val conf: SQLConf = SQLConf.get + private val conf: SQLConf = SQLConf.get // Unwrap the window expressions and window frame factories from the map. - val expressions = windowFrameExpressionFactoryPairs.flatMap(_._1) - val factories = windowFrameExpressionFactoryPairs.map(_._2).toArray - val inMemoryThreshold = conf.windowExecBufferInMemoryThreshold - val spillThreshold = conf.windowExecBufferSpillThreshold + private val expressions = windowFrameExpressionFactoryPairs.flatMap(_._1) + private val factories = windowFrameExpressionFactoryPairs.map(_._2).toArray + private val inMemoryThreshold = conf.windowExecBufferInMemoryThreshold + private val spillThreshold = conf.windowExecBufferSpillThreshold override def eval( partitionIndex: Int,