Class/Object

org.apache.spark.sql.execution.cms

TopKCMS

Related Docs: object TopKCMS | package cms

Permalink

final class TopKCMS[T] extends CountMinSketch[T]

Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TopKCMS
  2. CountMinSketch
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new TopKCMS(topKActual: Int, topKInternal: Int, depth: Int, width: Int, size: Long, hashA: Array[Long], table: Array[Array[Long]], confidence: Double, eps: Double)(implicit arg0: ClassTag[T])

    Permalink
  2. new TopKCMS(topKActual: Int, topKInternal: Int, epsOfTotalCount: Double, confidence: Double, seed: Int)(implicit arg0: ClassTag[T])

    Permalink
  3. new TopKCMS(topKActual: Int, topKInternal: Int, depth: Int, width: Int, hashA: Array[Long], confidence: Double, eps: Double)(implicit arg0: ClassTag[T])

    Permalink
  4. new TopKCMS(topKActual: Int, topKInternal: Int, depth: Int, width: Int, seed: Int)(implicit arg0: ClassTag[T])

    Permalink
  5. new TopKCMS(topKActual: Int, topKInternal: Int, depth: Int, width: Int, seed: Int, eps: Double, confidence: Double, size: Long, table: Array[Array[Long]], hashA: Array[Long], topkSet: BoundedSortedSet[T, Long])(implicit arg0: ClassTag[T])

    Permalink

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  4. def add(item: T, count: Long): Long

    Permalink

    Returns the currrent total count for the key

    Returns the currrent total count for the key

    Definition Classes
    TopKCMSCountMinSketch
  5. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  6. def clone(): CountMinSketch[T]

    Permalink
    Definition Classes
    CountMinSketch → AnyRef
  7. def compress: CountMinSketch[T]

    Permalink

    TODO Should this compress in place? Returns a new CountMinSketch that has half the width of this CMS.

    TODO Should this compress in place? Returns a new CountMinSketch that has half the width of this CMS. Each of the w/2 columns of the new CMS has the combined counts of the ith and ith+w/2 columns of this CMS. See the Hokusai paper for details.

    returns

    A new CountMinSketch that is the compressed version of this

    Definition Classes
    CountMinSketch
    Annotations
    @throws( ... )
    Exceptions thrown

    CMSCompressException if this CMS's width is not a power of two, or is too small.

  8. val confidence: Double

    Permalink
    Definition Classes
    CountMinSketch
  9. val depth: Int

    Permalink
    Definition Classes
    CountMinSketch
  10. val eps: Double

    Permalink
    Definition Classes
    CountMinSketch
  11. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  12. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  13. def estimateCount(item: T): Long

    Permalink

    The estimate is correct within 'epsilon' * (total item count), with probability 'confidence'.

    The estimate is correct within 'epsilon' * (total item count), with probability 'confidence'.

    Definition Classes
    CountMinSketch
  14. def estimateCountAsApproximate(item: T): Approximate

    Permalink
    Definition Classes
    CountMinSketch
  15. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  16. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
  17. def getConfidence: Double

    Permalink
    Definition Classes
    CountMinSketch
  18. def getFromTopKMap(key: T): Option[Approximate]

    Permalink
  19. def getIHashesFor(item: T, applyWidth: Boolean): Array[Int]

    Permalink
    Definition Classes
    CountMinSketch
  20. def getRelativeError: Double

    Permalink
    Definition Classes
    CountMinSketch
  21. def getSize: Long

    Permalink
    Definition Classes
    CountMinSketch
  22. def getTable: Array[Array[Long]]

    Permalink
    Definition Classes
    CountMinSketch
  23. def getTopK: Array[(T, Approximate)]

    Permalink
  24. def getTopKKeys: OpenHashSet[T]

    Permalink
  25. def getTopKeys: Set[T]

    Permalink
  26. val hashA: Array[Long]

    Permalink
    Definition Classes
    CountMinSketch
  27. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  28. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  29. val isTuple: Boolean

    Permalink
    Definition Classes
    CountMinSketch
  30. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  31. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  32. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  33. val seed: Int

    Permalink
    Definition Classes
    CountMinSketch
  34. var size: Long

    Permalink
    Definition Classes
    CountMinSketch
  35. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef
  36. val table: Array[Array[Long]]

    Permalink
    Definition Classes
    CountMinSketch
  37. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any
  38. val topKActual: Int

    Permalink
  39. val topKInternal: Int

    Permalink
  40. val topkSet: BoundedSortedSet[T, Long]

    Permalink
  41. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  42. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  43. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  44. val width: Int

    Permalink
    Definition Classes
    CountMinSketch
  45. def wrapAsApproximate(estimate: Long): Approximate

    Permalink
    Definition Classes
    CountMinSketch

Inherited from CountMinSketch[T]

Inherited from AnyRef

Inherited from Any

Ungrouped