This project has retired. For details please refer to its Attic page.
PGroupedTableType (Apache Crunch 0.7.0 API)

org.apache.crunch.types
Class PGroupedTableType<K,V>

java.lang.Object
  extended by org.apache.crunch.types.PGroupedTableType<K,V>
All Implemented Interfaces:
Serializable, PType<Pair<K,Iterable<V>>>

public abstract class PGroupedTableType<K,V>
extends Object
implements PType<Pair<K,Iterable<V>>>

The PType instance for PGroupedTable instances. Its settings are derived from the PTableType that was grouped to create the PGroupedTable instance.

See Also:
Serialized Form

Nested Class Summary
static class PGroupedTableType.PairIterableMapFn<K,V>
           
 
Constructor Summary
PGroupedTableType(PTableType<K,V> tableType)
           
 
Method Summary
abstract  void configureShuffle(org.apache.hadoop.mapreduce.Job job, GroupingOptions options)
           
 Converter getConverter()
           
 ReadableSourceTarget<Pair<K,Iterable<V>>> getDefaultFileSource(org.apache.hadoop.fs.Path path)
          Returns a SourceTarget that is able to read/write data using the serialization format specified by this PType.
 PTypeFamily getFamily()
          Returns the PTypeFamily that this PType belongs to.
abstract  Converter getGroupingConverter()
           
 List<PType> getSubTypes()
          Returns the sub-types that make up this PType if it is a composite instance, such as a tuple.
 PTableType<K,V> getTableType()
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.apache.crunch.types.PType
getDetachedValue, getInputMapFn, getOutputMapFn, getTypeClass, initialize
 

Constructor Detail

PGroupedTableType

public PGroupedTableType(PTableType<K,V> tableType)
Method Detail

getTableType

public PTableType<K,V> getTableType()

getFamily

public PTypeFamily getFamily()
Description copied from interface: PType
Returns the PTypeFamily that this PType belongs to.

Specified by:
getFamily in interface PType<Pair<K,Iterable<V>>>

getSubTypes

public List<PType> getSubTypes()
Description copied from interface: PType
Returns the sub-types that make up this PType if it is a composite instance, such as a tuple.

Specified by:
getSubTypes in interface PType<Pair<K,Iterable<V>>>

getConverter

public Converter getConverter()
Specified by:
getConverter in interface PType<Pair<K,Iterable<V>>>

getGroupingConverter

public abstract Converter getGroupingConverter()

configureShuffle

public abstract void configureShuffle(org.apache.hadoop.mapreduce.Job job,
                                      GroupingOptions options)

getDefaultFileSource

public ReadableSourceTarget<Pair<K,Iterable<V>>> getDefaultFileSource(org.apache.hadoop.fs.Path path)
Description copied from interface: PType
Returns a SourceTarget that is able to read/write data using the serialization format specified by this PType.

Specified by:
getDefaultFileSource in interface PType<Pair<K,Iterable<V>>>


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