A trait to enable logging all Akka actor messages.
An interface to represent clocks, so that they can be mocked out in unit tests.
An event bus which posts events to its listeners.
:: DeveloperApi ::
Various utility classes for working with Akka.
Asynchronously passes events to registered listeners.
Bounded priority queue.
Reads data from a ByteBuffer, and optionally cleans it up using BlockManager.dispose() at the end of the stream (e.g.
CallSite represents a place in user code.
A mutable class loader that gives preference to its own URLs over the parent class loader when loading classes and resources.
|CompletionIterator<A,I extends scala.collection.Iterator<A>>||
Wrapper around an iterator which calls a completion method after it successfully iterates through all the elements.
Util for getting some stats from a small sample of numeric values, with some handy summary functions.
An event loop to receive events from the caller and process all events in the event thread.
A util used to get a unique generation ID.
An extractor object for parsing strings into integers.
Serializes SparkListener events to/from JSON.
An extractor object for parsing JVM memory strings, such as "10g", into an Int representing the number of megabytes.
Runs a timer task to periodically clean up metadata (e.g.
:: DeveloperApi :: A tuple of 2 elements.
URL class loader that exposes the
Provides a basic/boilerplate Iterator implementation.
A class loader which makes some protected methods in ClassLoader accesible.
A utility class to redirect the child process's stdout or stderr.
A wrapper around a java.nio.ByteBuffer that is serializable through Java serialization, to make it easier to pass ByteBuffers in case class messages.
Used to log signals received.
Estimates the sizes of Java objects (number of bytes of memory they occupy), for use in memory-aware caches.
The default uncaught exception handler for Executors terminates the whole process, to avoid getting into a bad state indefinitely.
A class for tracking the statistics of a set of numbers (count, mean and variance) in a numerically robust way.
A clock backed by the actual time from the OS as reported by the
Used for shipping per-thread stacktraces from the executors to driver.
This is a custom implementation of scala.collection.mutable.Map which stores the insertion timestamp along with each key-value pair.
A wrapper of TimeStampedHashMap that ensures the values are weakly referenced and timestamped.
Various utility methods used by Spark.
Exception thrown when there is an exception in executing the callback in TaskCompletionListener.