com.cloudera.crunch.type
Class PGroupedTableType<K,V>

java.lang.Object
  com.cloudera.crunch.type.PGroupedTableType<K,V>

All Implemented Interfaces:

PType<Pair<K,Iterable<V>>>

Direct Known Subclasses:

AvroGroupedTableType, WritableGroupedTableType

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.

Nested Class Summary

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()
SourceTarget<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 com.cloudera.crunch.type.PType

getInputMapFn, getOutputMapFn, getTypeClass

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