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

Nested Classes

Modifier and Type	Class and Description
static class	PGroupedTableType.PairIterableMapFn<K,V>

Constructor Summary

Constructors

Constructor and Description
PGroupedTableType(PTableType<K,V> tableType)

Method Summary

Modifier and Type	Method and Description
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

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