case class ApproximateUniqueCounterByError[T](maximumEstimationError: Double = 0.02) extends ApproxDistinctCounter[T] with Product with Serializable
ApproxDistinctCounter impl for org.apache.beam.sdk.transforms.ApproximateUnique with maximum estimation error.
Count approximate number of distinct elements in the SCollection.
- maximumEstimationError
the maximum estimation error, which should be in the range
[0.01, 0.5]
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- ApproximateUniqueCounterByError
- Serializable
- Product
- Equals
- ApproxDistinctCounter
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
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
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def estimateDistinctCount(in: SCollection[T]): SCollection[Long]
Return a SCollection with single (Long)value which is the estimated distinct count in the given SCollection with type
TReturn a SCollection with single (Long)value which is the estimated distinct count in the given SCollection with type
T- Definition Classes
- ApproximateUniqueCounterByError → ApproxDistinctCounter
- def estimateDistinctCountPerKey[K](in: SCollection[(K, T)]): SCollection[(K, Long)]
Approximate distinct element per each key in the given key value SCollection.
Approximate distinct element per each key in the given key value SCollection. This will output estimated distinct count per each unique key.
- Definition Classes
- ApproximateUniqueCounterByError → ApproxDistinctCounter
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val maximumEstimationError: Double
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- 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()