Moved BatchInfo from streaming.scheduler to streaming.ui

Author: tdas

streaming/src/main/scala/org/apache/spark/streaming/scheduler/JobSet.scala

@@ -19,6 +19,7 @@ package org.apache.spark.streaming.scheduler
 
 import scala.collection.mutable.{ArrayBuffer, HashSet}
 import org.apache.spark.streaming.Time
+import org.apache.spark.streaming.ui.BatchInfo
 
 /** Class representing a set of Jobs
   * belong to the same batch.

streaming/src/main/scala/org/apache/spark/streaming/scheduler/StreamingListener.scala

@@ -20,6 +20,7 @@ package org.apache.spark.streaming.scheduler
 import scala.collection.mutable.Queue
 
 import org.apache.spark.util.Distribution
+import org.apache.spark.streaming.ui.BatchInfo
 
 /** Base trait for events related to StreamingListener */
 sealed trait StreamingListenerEvent

streaming/src/main/scala/org/apache/spark/streaming/scheduler/BatchInfo.scala renamed to streaming/src/main/scala/org/apache/spark/streaming/ui/BatchInfo.scala

@@ -15,9 +15,10 @@
  * limitations under the License.
  */
 
-package org.apache.spark.streaming.scheduler
+package org.apache.spark.streaming.ui
 
 import org.apache.spark.streaming.Time
+import org.apache.spark.streaming.scheduler.ReceivedBlockInfo
 
 /**
  * Class having information on completed batches.

streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingJobProgressListener.scala

@@ -22,7 +22,6 @@ import org.apache.spark.streaming.scheduler._
 import scala.collection.mutable.{Queue, HashMap}
 import org.apache.spark.streaming.scheduler.StreamingListenerReceiverStarted
 import org.apache.spark.streaming.scheduler.StreamingListenerBatchStarted
-import org.apache.spark.streaming.scheduler.BatchInfo
 import org.apache.spark.streaming.scheduler.StreamingListenerBatchSubmitted
 import org.apache.spark.util.Distribution
 import org.apache.spark.Logging

streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala

@@ -25,7 +25,7 @@ import org.apache.spark.storage.StorageLevel
 import org.apache.spark.streaming.dstream.DStream
 import org.apache.spark.streaming.receiver.Receiver
 import org.apache.spark.streaming.scheduler._
-import org.apache.spark.streaming.ui.ReceiverInfo
+import org.apache.spark.streaming.ui.{BatchInfo, ReceiverInfo}
 
 import org.scalatest.matchers.ShouldMatchers
 import org.scalatest.concurrent.Eventually._