com.datasolvr.services.spark.functions
PointsAfterOutlierTracker
Companion object PointsAfterOutlierTracker
class PointsAfterOutlierTracker extends AnyRef
- Alphabetic
- By Inheritance
- PointsAfterOutlierTracker
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new PointsAfterOutlierTracker()
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def addPoints(pointsIsOutlier: List[(Point, Boolean)]): Unit
- pointsIsOutlier
an array of tuples containing a point and a boolean that is true if the point is an outlier
- def addPoints(points: List[Point], isOutlierFunction: (Point) => Boolean): Unit
adds points to pointsAfterOutlier, and calculates consecutiveOutliersCount with new points
adds points to pointsAfterOutlier, and calculates consecutiveOutliersCount with new points
- isOutlierFunction
function that maps from point to being an outlier
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- def consecutiveOutliersCountIsMin: Boolean
true if consecutiveOutliersCount == consecutiveOutliersCountMinVal
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def flushPoints(): List[Point]
returns pointsAfterOutlier and then resets tracker, i.e.
returns pointsAfterOutlier and then resets tracker, i.e. pointsAfterOutlier becomes empty array and consecutiveOutliersCount is is set to 0
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def getConsecutiveOutliersCount: Option[Int]
equals amount of outliers that are next to each other, where every space (point that is not an outlier) subtracts one from the result
equals amount of outliers that are next to each other, where every space (point that is not an outlier) subtracts one from the result
if O means outlier and o means not outlier, then these lists of points, i.e. the points in pointsAfterOutlier would return:
- OoOOo => 1
- oooO => 1
- oOOoo => 0
Example: - def getPoints: List[Point]
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def isEmpty: Boolean
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def removePointsUntilOutlierFound(isOutlierFunction: (Point) => Boolean): List[Point]
Removes points from pointsAfterOutlier until an outlier is found, and returns the removed points
Removes points from pointsAfterOutlier until an outlier is found, and returns the removed points
- returns
points from left to right terminating at first outlier found after reevaluating whether a point is an outlier with isOutlierFunction
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)