Packages

package util

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Type Members

  1. trait Cache[K, V] extends Serializable
  2. trait CacheT[K, V, U] extends Cache[K, V]
  3. trait FilenamePolicySupplier extends AnyRef
  4. trait MultiJoin extends Serializable
  5. class RemoteFileUtil extends Serializable

    A utility class for handling remote file systems designed to be used in a org.apache.beam.sdk.transforms.DoFn.

  6. 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.

  7. 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) from K to U.

    Similar to com.google.common.cache.ForwardingCache but with key transformation using the injective function #transformKey(K) from K to U.
    This cache won't be able to return original keys, hence #getAllPresent(Iterable) and #asMap() both throw an UnsupportedOperationException.

Value Members

  1. object Cache extends Serializable
  2. object FilenamePolicySupplier
  3. object MultiJoin extends MultiJoin
  4. object StatCounter extends Serializable

Ungrouped