c

com.spotify.scio.values

DoubleSCollectionFunctions

class DoubleSCollectionFunctions extends AnyRef

Extra functions available on SCollections of Doubles through an implicit conversion.

Source
DoubleSCollectionFunctions.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. DoubleSCollectionFunctions
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new DoubleSCollectionFunctions(self: SCollection[Double])

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. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  8. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  9. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  10. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  11. def histogram(buckets: Array[Double], evenBuckets: Boolean = false): SCollection[Array[Long]]

    Compute a histogram using the provided buckets.

    Compute a histogram using the provided buckets. The buckets are all open to the right except for the last which is closed e.g. for the array [1, 10, 20, 50] the buckets are [1, 10) [10, 20) [20, 50] e.g 1<=x<10, 10<=x<20, 20<=x<=50. And on the input of 1 and 50 we would have a histogram of [1, 0, 1].

    Note: if your histogram is evenly spaced (e.g. [0, 10, 20, 30]) this can be switched from an O(log n) insertion to O(1) per element. (where n = # buckets) if you set evenBuckets to true.

    buckets must be sorted and not contain any duplicates. buckets array must be at least two elements. All NaN entries are treated the same. If you have a NaN bucket it must be the maximum value of the last position and all NaN entries will be counted in that bucket.

  12. def histogram(bucketCount: Int): (SCollection[Array[Double]], SCollection[Array[Long]])

    Compute a histogram of the data using bucketCount number of buckets evenly spaced between the minimum and maximum of the SCollection.

    Compute a histogram of the data using bucketCount number of buckets evenly spaced between the minimum and maximum of the SCollection. For example if the min value is 0 and the max is 100 and there are two buckets the resulting buckets will be [0, 50) [50, 100]. bucketCount must be at least 1. If the SCollection contains infinity, NaN throws an exception. If the elements in SCollection do not vary (max == min) always returns a single bucket.

  13. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  14. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  15. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  16. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  17. def sampleStdev: SCollection[Double]

    Compute the sample standard deviation of this SCollection's elements (which corrects for bias in estimating the standard deviation by dividing by N-1 instead of N).

  18. def sampleVariance: SCollection[Double]

    Compute the sample variance of this SCollection's elements (which corrects for bias in estimating the variance by dividing by N-1 instead of N).

  19. def stats: SCollection[StatCounter]

    Return an SCollection with a single StatCounter object that captures the mean, variance and count of the SCollection's elements in one operation.

  20. def stdev: SCollection[Double]

    Compute the standard deviation of this SCollection's elements.

  21. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  22. def toString(): String
    Definition Classes
    AnyRef → Any
  23. def variance: SCollection[Double]

    Compute the variance of this SCollection's elements.

  24. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  25. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  26. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped