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

protected static class	PGroupedTableType.HoldLastIterator<V>
static class	PGroupedTableType.PairIterableMapFn<K,V>
protected static class	PGroupedTableType.PTypeIterable<V>

Field Summary

protected PTableType<K,V>

tableType

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

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.crunch.types.PType

getDetachedValue, getInputMapFn, getOutputMapFn, getTypeClass, initialize

Field Detail

tableType

protected final PTableType<K,V> tableType

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>>>