Skip to content

Commit d7f849c

Browse files
committed
Revert "Moved BatchInfo from streaming.scheduler to streaming.ui"
This reverts commit 5c80919.
1 parent 5c80919 commit d7f849c

File tree

5 files changed

+3
-5
lines changed

5 files changed

+3
-5
lines changed

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,10 +15,9 @@
1515
* limitations under the License.
1616
*/
1717

18-
package org.apache.spark.streaming.ui
18+
package org.apache.spark.streaming.scheduler
1919

2020
import org.apache.spark.streaming.Time
21-
import org.apache.spark.streaming.scheduler.ReceivedBlockInfo
2221

2322
/**
2423
* Class having information on completed batches.

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

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,6 @@ package org.apache.spark.streaming.scheduler
1919

2020
import scala.collection.mutable.{ArrayBuffer, HashSet}
2121
import org.apache.spark.streaming.Time
22-
import org.apache.spark.streaming.ui.BatchInfo
2322

2423
/** Class representing a set of Jobs
2524
* belong to the same batch.

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

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@ package org.apache.spark.streaming.scheduler
2020
import scala.collection.mutable.Queue
2121

2222
import org.apache.spark.util.Distribution
23-
import org.apache.spark.streaming.ui.BatchInfo
2423

2524
/** Base trait for events related to StreamingListener */
2625
sealed trait StreamingListenerEvent

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@ import org.apache.spark.streaming.scheduler._
2222
import scala.collection.mutable.{Queue, HashMap}
2323
import org.apache.spark.streaming.scheduler.StreamingListenerReceiverStarted
2424
import org.apache.spark.streaming.scheduler.StreamingListenerBatchStarted
25+
import org.apache.spark.streaming.scheduler.BatchInfo
2526
import org.apache.spark.streaming.scheduler.StreamingListenerBatchSubmitted
2627
import org.apache.spark.util.Distribution
2728
import org.apache.spark.Logging

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ import org.apache.spark.storage.StorageLevel
2525
import org.apache.spark.streaming.dstream.DStream
2626
import org.apache.spark.streaming.receiver.Receiver
2727
import org.apache.spark.streaming.scheduler._
28-
import org.apache.spark.streaming.ui.{BatchInfo, ReceiverInfo}
28+
import org.apache.spark.streaming.ui.ReceiverInfo
2929

3030
import org.scalatest.matchers.ShouldMatchers
3131
import org.scalatest.concurrent.Eventually._

0 commit comments

Comments
 (0)