Fix scala checkstyle

Author: HeartSaVioR

sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/MergingSessionsExec.scala

@@ -17,8 +17,6 @@
 
 package org.apache.spark.sql.execution.aggregate
 
-import org.apache.spark.TaskContext
-
 import org.apache.spark.rdd.RDD
 import org.apache.spark.sql.catalyst.InternalRow
 import org.apache.spark.sql.catalyst.expressions.{Ascending, Attribute, AttributeSet, Expression, NamedExpression, SortOrder, UnsafeRow}

sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/MergingSessionsIterator.scala

@@ -54,9 +54,9 @@ class MergingSessionsIterator(
 
 
   /**
-    * Creates a new aggregation buffer and initializes buffer values
-    * for all aggregate functions.
-    */
+   * Creates a new aggregation buffer and initializes buffer values
+   * for all aggregate functions.
+   */
   private def newBuffer: InternalRow = {
     val bufferSchema = aggregateFunctions.flatMap(_.aggBufferAttributes)
     val bufferRowSize: Int = bufferSchema.length

sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/UpdatingSessionExec.scala

@@ -17,12 +17,9 @@
 
 package org.apache.spark.sql.execution.aggregate
 
-import org.apache.spark.TaskContext
-
 import org.apache.spark.rdd.RDD
 import org.apache.spark.sql.catalyst.InternalRow
 import org.apache.spark.sql.catalyst.expressions.{Attribute, SortOrder}
-import org.apache.spark.sql.catalyst.expressions.codegen.GenerateUnsafeProjection
 import org.apache.spark.sql.catalyst.plans.physical.{Distribution, Partitioning}
 import org.apache.spark.sql.execution.{SparkPlan, UnaryExecNode}
 
@@ -56,4 +53,4 @@ case class UpdatingSessionExec(
     case Some(ordering) => ordering
     case None => super.requiredChildOrdering
   }
-}
+}

sql/core/src/main/scala/org/apache/spark/sql/execution/python/AggregateInPandasExec.scala

@@ -22,7 +22,6 @@ import java.io.File
 import scala.collection.mutable.ArrayBuffer
 
 import org.apache.spark.{SparkEnv, TaskContext}
-
 import org.apache.spark.api.python.{ChainedPythonFunctions, PythonEvalType}
 import org.apache.spark.rdd.RDD
 import org.apache.spark.sql.catalyst.InternalRow

sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/MultiValuesStateStoreRDD.scala

@@ -48,9 +48,9 @@ class MultiValuesStateStoreRDD[T: ClassTag, U: ClassTag](
   override protected def getPartitions: Array[Partition] = dataRDD.partitions
 
   /**
-    * Set the preferred location of each partition using the executor that has the related
-    * [[StateStoreProvider]] already loaded.
-    */
+   * Set the preferred location of each partition using the executor that has the related
+   * [[StateStoreProvider]] already loaded.
+   */
   override def getPreferredLocations(partition: Partition): Seq[String] = {
     val stateStoreProviderId = StateStoreProviderId(
       StateStoreId(stateInfo.checkpointLocation, stateInfo.operatorId, partition.index),

sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/statefulOperators.scala

@@ -21,9 +21,6 @@ import java.util.UUID
 import java.util.concurrent.TimeUnit._
 
 import scala.collection.JavaConverters._
-import scala.collection.mutable
-
-import org.apache.spark.TaskContext
 
 import org.apache.spark.rdd.RDD
 import org.apache.spark.sql.catalyst.InternalRow

sql/core/src/test/scala/org/apache/spark/sql/execution/streaming/MergingSortWithMultiValuesStateIteratorSuite.scala

@@ -272,4 +272,4 @@ class MergingSortWithMultiValuesStateIteratorSuite extends SharedSQLContext {
     }
     StateStore.stop()
   }
-}
+}