See: Description
Class | Description |
---|---|
ApproximateDistinct |
PTransform s 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
DoFn s to retrieve the cardinality from a HyperLogLogPlus structure in a global or perKey context. |
SketchFrequencies |
PTransform s 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.
|