|
|||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |
See:
Description
Interface Summary | |
---|---|
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 | |
---|---|
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. |
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> |
An assorted set of utilities.
|
|||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |