See: Description
Interface | Description |
---|---|
Converter<K,V,S,T> |
Converts the input key/value from a MapReduce task into the input to a
DoFn , or takes the output of a DoFn and write it to the
output key/values. |
DeepCopier<T> |
Performs deep copies of values.
|
PTableType<K,V> |
An extension of
PType specifically for PTable objects. |
PType<T> |
A
PType defines a mapping between a data type that is used in a Crunch pipeline and a
serialization and storage format that is used to read/write data from/to HDFS. |
PTypeFamily |
An abstract factory for creating
PType instances that have the same
serialization/storage backing format. |
Class | Description |
---|---|
CollectionDeepCopier<T> |
Performs deep copies (based on underlying PType deep copying) of Collections.
|
DeepCopier.NoOpDeepCopier<V> | |
MapDeepCopier<T> | |
PGroupedTableType<K,V> |
The
PType instance for PGroupedTable instances. |
PGroupedTableType.PairIterableMapFn<K,V> | |
Protos |
Utility functions for working with protocol buffers in Crunch.
|
PTypes |
Utility functions for creating common types of derived PTypes, e.g., for JSON
data, protocol buffers, and Thrift records.
|
PTypeUtils |
Utilities for converting between
PType s from different
PTypeFamily implementations. |
TupleDeepCopier<T extends Tuple> |
Performs deep copies (based on underlying PType deep copying) of Tuple-based objects.
|
TupleFactory<T extends Tuple> |
Copyright © 2013 The Apache Software Foundation. All Rights Reserved.