Package org.apache.crunch.util

An assorted set of utilities.

See: Description

Interface Summary

Interface	Description
SerializableSupplier<T>	An extension of Guava's Supplier interface that indicates that an instance will also implement Serializable, which makes this object suitable for use with Crunch's DoFns when we need to construct an instance of a non-serializable type for use in processing.

Class Summary

Class	Description
ClassloaderFallbackObjectInputStream	A custom ObjectInputStream that falls back to the thread context classloader if the class can't be found with the usual classloader that ObjectInputStream uses.
CrunchTool	An extension of the Tool interface that creates a Pipeline instance and provides methods for working with the Pipeline from inside of the Tool's run method.
DelegatingReadableData<S,T>	Implements the ReadableData<T> interface by delegating to an ReadableData<S> instance and passing its contents through a DoFn<S, T>.
DistCache	Provides functions for working with Hadoop's distributed cache.
DoFnIterator<S,T>	An Iterator<T> that combines a delegate Iterator<S> and a DoFn<S, T>, generating data by passing the contents of the iterator through the function.
HashUtil	Utility methods for working with hash codes.
PartitionUtils	Helper functions and settings for determining the number of reducers to use in a pipeline job created by the Crunch planner.
Tuples	Utilities for working with subclasses of the Tuple interface.
Tuples.PairIterable<S,T>
Tuples.QuadIterable<A,B,C,D>
Tuples.TripIterable<A,B,C>
Tuples.TupleNIterable
UnionReadableData<T>

Package org.apache.crunch.util Description

An assorted set of utilities.