This project has retired. For details please refer to its Attic page.

Package org.apache.crunch.types

Common functionality for business object serialization.

See:
Description

Interface Summary

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 Summary

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.
Protos.ExtractKeyFn<M extends Message,K>
Protos.TextToProtoFn<M extends Message>
PTypes	Utility functions for creating common types of derived PTypes, e.g., for JSON data, protocol buffers, and Thrift records.
PTypes.EnumInputMapper<T extends Enum>
PTypes.EnumOutputMapper<T extends Enum>
PTypes.JacksonInputMapFn<T>
PTypes.JacksonOutputMapFn<T>
PTypes.ProtoInputMapFn<T extends Message>
PTypes.ProtoOutputMapFn<T extends Message>
PTypes.ThriftInputMapFn<T extends TBase>
PTypes.ThriftOutputMapFn<T extends TBase>
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>

Package org.apache.crunch.types Description

Common functionality for business object serialization.