package util
- Alphabetic
- Public
- Protected
Type Members
- trait Cache[K, V] extends Serializable
- trait CacheT[K, V, U] extends Cache[K, V]
- trait FilenamePolicySupplier extends AnyRef
- trait MultiJoin extends Serializable
- class RemoteFileUtil extends Serializable
A utility class for handling remote file systems designed to be used in a
DoFn
. - class StatCounter extends Serializable
A class for tracking the statistics of a set of numbers (count, mean and variance) in a numerically robust way.
A class for tracking the statistics of a set of numbers (count, mean and variance) in a numerically robust way. Includes support for merging two StatCounters. Based on Welford and Chan's algorithms for running variance.
- abstract class TransformingCache[K, U, V] extends ForwardingObject with google.common.cache.Cache[K, V]
Similar to
com.google.common.cache.ForwardingCache
but with key transformation using the injective function#transformKey(K)
fromK
toU
.Similar to
com.google.common.cache.ForwardingCache
but with key transformation using the injective function#transformKey(K)
fromK
toU
.
This cache won't be able to return original keys, hence#getAllPresent(Iterable)
and#asMap()
both throw anUnsupportedOperationException
.
Value Members
- object Cache extends Serializable
- object FilenamePolicySupplier
- object MultiJoin extends MultiJoin
- object StatCounter extends Serializable