We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1f73eac commit 55fb6f6Copy full SHA for 55fb6f6
core/src/main/scala/org/apache/spark/util/EventLoop.scala
@@ -27,7 +27,7 @@ import org.apache.spark.Logging
27
* An event loop to receive events from the caller and process all events in the event thread. It
28
* will start an exclusive event thread to process all events.
29
*/
30
-abstract class EventLoop[E](name: String) extends Logging {
+private[spark] abstract class EventLoop[E](name: String) extends Logging {
31
32
private val eventQueue: BlockingQueue[E] = new LinkedBlockingDeque[E]()
33
0 commit comments