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

java.lang.Object
  com.cloudera.crunch.type.avro.AvroType<Pair<K,V>>
      com.cloudera.crunch.type.avro.AvroTableType<K,V>

All Implemented Interfaces:

PTableType<K,V>, PType<Pair<K,V>>

public class AvroTableType<K,V>
extends AvroType<Pair<K,V>>
implements PTableType<K,V>

The implementation of the PTableType interface for Avro-based serialization.

Constructor Summary

AvroTableType(AvroType<K> keyType, AvroType<V> valueType, Class<Pair<K,V>> pairClass)

Method Summary

PGroupedTableType<K,V>	getGroupedTableType() Returns the grouped table version of this type.
PType<K>	getKeyType() Returns the key type for the table.
PType<V>	getValueType() Returns the value type for the table.

Methods inherited from class com.cloudera.crunch.type.avro.AvroType

equals, getConverter, getDefaultFileSource, getFamily, getInputMapFn, getOutputMapFn, getSchema, getSubTypes, getTypeClass, hashCode, isSpecific

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.cloudera.crunch.type.PType

getConverter, getDefaultFileSource, getFamily, getInputMapFn, getOutputMapFn, getSubTypes, getTypeClass

Constructor Detail

AvroTableType

public AvroTableType(AvroType<K> keyType,
                     AvroType<V> valueType,
                     Class<Pair<K,V>> pairClass)

Method Detail

getKeyType

public PType<K> getKeyType()

Description copied from interface: PTableType

Returns the key type for the table.

Specified by:

getKeyType in interface PTableType<K,V>

getValueType

public PType<V> getValueType()

Description copied from interface: PTableType

Returns the value type for the table.

Specified by:

getValueType in interface PTableType<K,V>

getGroupedTableType

public PGroupedTableType<K,V> getGroupedTableType()

Description copied from interface: PTableType

Returns the grouped table version of this type.

Specified by:

getGroupedTableType in interface PTableType<K,V>