Update code

apache · Jul 17, 2023 · ad88985 · ad88985
1 parent 8a42a38
commit ad88985
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/...src/main/scala/org/apache/spark/sql/execution/python/WindowInPandasEvaluatorFactory.scala b/...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
@@ -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,