org.apache.spark.streamdm.clusterers.clusters

MicroCluster

case class MicroCluster(sum: Instance, sqSum: Instance, timeSum: Long, sqTimeSum: Double, num: Int) extends Serializable with Product

A MicroCluster contains the underlying structure for the Clustream processing framework, and summarizes a number of instances belonging to the same MicroCluster. It is composed of: - the number of instance - the sum of instances - the sum of squared instance - the sum of timestamps - the squared sum of timestamps.

Linear Supertypes
Product, Equals, Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. MicroCluster
  2. Product
  3. Equals
  4. Serializable
  5. Serializable
  6. AnyRef
  7. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new MicroCluster(sum: Instance, sqSum: Instance, timeSum: Long, sqTimeSum: Double, num: Int)

Value Members

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

    Definition Classes
    AnyRef

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

    Definition Classes
    Any

  3. final def ##(): Int

    Definition Classes
    AnyRef → Any

  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any

  6. final def asInstanceOf[T0]: T0

    Definition Classes
    Any

  7. def centroid: Instance

    Compute the centroid of a Microcluster.

    Compute the centroid of a Microcluster.

    returns

    an instance representing the centroid

  8. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  9. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  10. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )

  11. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any

  12. def insert(inst: Instance, time: Long): MicroCluster

    Insert an instance into the microcluster.

    Insert an instance into the microcluster.

    inst

    the Instance which needs a class predicted

    time

    the timestamp of the Instance

    returns

    the new MicroCluster

  13. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any

  14. def merge(other: MicroCluster): MicroCluster

    Merges two microclusters together.

    Merges two microclusters together.

    other

    the MicroCluster which gets added

    returns

    the new MicroCluster

  15. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  16. final def notify(): Unit

    Definition Classes
    AnyRef

  17. final def notifyAll(): Unit

    Definition Classes
    AnyRef

  18. val num: Int

  19. def rmse: Double

    Compute the RMSE of a microcluster.

    Compute the RMSE of a microcluster.

    returns

    the RMSE of a microcluster

  20. val sqSum: Instance

  21. val sqTimeSum: Double

  22. val sum: Instance

  23. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef

  24. def threshold(m: Int): Double

    Compute the threshold timestamp of the microcluster.

    Compute the threshold timestamp of the microcluster.

    returns

    the threshold timestamp

  25. val timeSum: Long

  26. def toExample: Example

    Return the microcluster as a weighted Example, containing the centroid and the number of elements.

    Return the microcluster as a weighted Example, containing the centroid and the number of elements.

    returns

    the output Example

  27. def toString(): String

    Definition Classes
    MicroCluster → AnyRef → Any

  28. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  29. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  30. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from Product

Inherited from Equals

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped