Addressed more comments

Author: tdas

sql/core/src/main/scala/org/apache/spark/sql/execution/objects.scala

@@ -31,6 +31,7 @@ import org.apache.spark.sql.catalyst.expressions.objects.Invoke
 import org.apache.spark.sql.catalyst.plans.physical._
 import org.apache.spark.sql.Row
 import org.apache.spark.sql.catalyst.plans.logical.LogicalKeyedState
+import org.apache.spark.sql.execution.streaming.KeyedStateImpl
 import org.apache.spark.sql.types.{DataType, ObjectType, StructType}
 
 

…spark/sql/execution/KeyedStateImpl.scala …execution/streaming/KeyedStateImpl.scalasql/core/src/main/scala/org/apache/spark/sql/execution/KeyedStateImpl.scala renamed to sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/KeyedStateImpl.scala sql/core/src/main/scala/org/apache/spark/sql/execution/KeyedStateImpl.scala renamed to sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/KeyedStateImpl.scala

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.spark.sql.execution
+package org.apache.spark.sql.execution.streaming
 
 import org.apache.spark.sql.KeyedState
 

…cution/streaming/StatefulAggregate.scala …cution/streaming/statefulOperators.scalasql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StatefulAggregate.scala renamed to sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/statefulOperators.scala sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/StatefulAggregate.scala renamed to sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/statefulOperators.scala

@@ -22,8 +22,7 @@ import org.scalatest.BeforeAndAfterAll
 import org.apache.spark.SparkException
 import org.apache.spark.sql.KeyedState
 import org.apache.spark.sql.catalyst.streaming.InternalOutputModes._
-import org.apache.spark.sql.execution.KeyedStateImpl
-import org.apache.spark.sql.execution.streaming.MemoryStream
+import org.apache.spark.sql.execution.streaming.{KeyedStateImpl, MemoryStream}
 import org.apache.spark.sql.execution.streaming.state.StateStore
 
 /** Class to check custom state types */