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

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

java.lang.Object
  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>>>