org.apache.spark

util

package util

Visibility
  1. Public
  2. All

Type Members

  1. class BoundedPriorityQueue[A] extends Iterable[A] with Growable[A] with Serializable

    Bounded priority queue.

  2. abstract class CompletionIterator[+A, +I <: Iterator[A]] extends Iterator[A]

    Wrapper around an iterator which calls a completion method after it successfully iterates through all the elements

  3. class Distribution extends AnyRef

    Util for getting some stats from a small sample of numeric values, with some handy summary functions.

  4. class MetadataCleaner extends Logging

    Runs a timer task to periodically clean up metadata (e.

  5. case class MutablePair[T1, T2](_1: T1, _2: T2) extends Product2[T1, T2] with Product with Serializable

    A tuple of 2 elements.

  6. class RateLimitedOutputStream extends OutputStream

  7. class StatCounter extends Serializable

    A class for tracking the statistics of a set of numbers (count, mean and variance) in a numerically robust way.

  8. class TimeStampedHashMap[A, B] extends Map[A, B] with Logging

    This is a custom implementation of scala.

  9. class TimeStampedHashSet[A] extends Set[A]

  10. class Vector extends Serializable

Value Members

  1. object CompletionIterator extends AnyRef

  2. object Distribution extends AnyRef

  3. object MetadataCleaner extends AnyRef

  4. object StatCounter extends Serializable

  5. object Vector extends Serializable