Packages

class StreamSummary[T] extends ITopK[T]

Based on the Space-Saving algorithm and the Stream-Summary data structure as described in: Efficient Computation of Frequent and Top-k Elements in Data Streams by Metwally, Agrawal, and Abbadi

T

type of data in the stream to be summarized

Linear Supertypes
ITopK[T], AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. StreamSummary
  2. ITopK
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. val capacity: Int
  6. def clear(): Unit
  7. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native() @IntrinsicCandidate()
  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  10. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  11. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  12. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  13. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  14. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  15. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  16. def offer(item: T, increment: Long): Boolean
  17. def offer(item: T, increment: Int): Boolean

    Algorithm: Space-Saving

    Algorithm: Space-Saving

    item

    stream element (e)

    returns

    false if item was already in the stream summary, true otherwise

    Definition Classes
    StreamSummary → ITopK
  18. def offer(item: T): Boolean

    Algorithm: Space-Saving

    Algorithm: Space-Saving

    item

    stream element (e)

    returns

    false if item was already in the stream summary, true otherwise

    Definition Classes
    StreamSummary → ITopK
  19. def offerReturnAll(item: T, increment: Long): (Boolean, T)

    item

    stream element (e)

    returns

    (isNewItem, itemDropped) where isNewItem is the return value of offer() and itemDropped is null if no item was dropped

  20. def offerReturnDropped(item: T, increment: Long): T

    item

    stream element (e)

    returns

    item dropped from summary if an item was dropped, null otherwise

  21. def peek(k: Int): List[T]
    Definition Classes
    StreamSummary → ITopK
  22. def size: Int
  23. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  24. def toString(): String
    Definition Classes
    StreamSummary → AnyRef → Any
  25. def topK(k: Int): Iterator[(T, Long)]
  26. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  27. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  28. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] ) @Deprecated
    Deprecated

Inherited from ITopK[T]

Inherited from AnyRef

Inherited from Any

Ungrouped