Package org.apache.crunch.types

Common functionality for business object serialization.


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.
PGroupedTableType<K,V> The PType instance for PGroupedTable instances.
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.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.

Copyright © 2012 The Apache Software Foundation. All Rights Reserved.