com.cloudera.crunch.type.avro
Class AvroGroupedTableType<K,V>

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

All Implemented Interfaces:

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

public class AvroGroupedTableType<K,V>
extends PGroupedTableType<K,V>

Nested Class Summary

Nested classes/interfaces inherited from class com.cloudera.crunch.type.PGroupedTableType

PGroupedTableType.PairIterableMapFn<K,V>, PGroupedTableType.PTypeIterable<V>

Field Summary

Fields inherited from class com.cloudera.crunch.type.PGroupedTableType

tableType

Constructor Summary

AvroGroupedTableType(AvroTableType<K,V> tableType)

Method Summary

void	configureShuffle(org.apache.hadoop.mapreduce.Job job, GroupingOptions options)
Converter	getGroupingConverter()
MapFn	getInputMapFn()
MapFn	getOutputMapFn()
Class<Pair<K,Iterable<V>>>	getTypeClass() Returns the Java type represented by this PType.

Methods inherited from class com.cloudera.crunch.type.PGroupedTableType

getConverter, getDefaultFileSource, getFamily, getSubTypes, getTableType

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroGroupedTableType

public AvroGroupedTableType(AvroTableType<K,V> tableType)

Method Detail

getTypeClass

public Class<Pair<K,Iterable<V>>> getTypeClass()

Description copied from interface: PType

Returns the Java type represented by this PType.

getGroupingConverter

public Converter getGroupingConverter()

Specified by:

getGroupingConverter in class PGroupedTableType<K,V>

getInputMapFn

public MapFn getInputMapFn()

getOutputMapFn

public MapFn getOutputMapFn()

configureShuffle

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

Specified by:

configureShuffle in class PGroupedTableType<K,V>