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.
|
| MapDeepCopier<T> | |
| NoOpDeepCopier<T> |
A
DeepCopier that does nothing, and just returns the input value without copying anything. |
| 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
PTypes 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> | |
| UnionDeepCopier |
Copyright © 2017 The Apache Software Foundation. All rights reserved.