See: Description
| Class | Description |
|---|---|
| ApproximateDistinct |
PTransforms for computing the approximate number of distinct elements in a stream. |
| ApproximateDistinct.ApproximateDistinctFn<InputT> |
Implements the
Combine.CombineFn of ApproximateDistinct transforms. |
| ApproximateDistinct.GloballyDistinct<InputT> |
Implementation of
ApproximateDistinct.globally(). |
| ApproximateDistinct.HyperLogLogPlusCoder |
Coder for
HyperLogLogPlus class. |
| ApproximateDistinct.PerKeyDistinct<K,V> |
Implementation of
ApproximateDistinct.perKey(). |
| ApproximateDistinct.RetrieveCardinality |
Utility class that provides
DoFns to retrieve the cardinality from a HyperLogLogPlus structure in a global or perKey context. |
| SketchFrequencies |
PTransforms to compute the estimate frequency of each element in a stream. |
| SketchFrequencies.CountMinSketchFn<InputT> |
Implements the
Combine.CombineFn of SketchFrequencies transforms. |
| SketchFrequencies.GlobalSketch<InputT> |
Implementation of
SketchFrequencies.globally(). |
| SketchFrequencies.PerKeySketch<K,V> |
Implementation of
SketchFrequencies.perKey(). |
| SketchFrequencies.Sketch<T> |
Wrap StreamLib's Count-Min Sketch to support counting all user types by hashing
the encoded user type using the supplied deterministic coder.
|
| TDigestQuantiles |
PTransforms for getting information about quantiles in a stream. |
| TDigestQuantiles.GlobalDigest |
Implementation of
TDigestQuantiles.globally(). |
| TDigestQuantiles.PerKeyDigest<K> |
Implementation of
TDigestQuantiles.perKey(). |
| TDigestQuantiles.TDigestQuantilesFn |
Implements the
Combine.CombineFn of TDigestQuantiles transforms. |