com.cloudera.crunch.type.writable
Class WritableGroupedTableType<K,V>
java.lang.Object
com.cloudera.crunch.type.PGroupedTableType<K,V>
com.cloudera.crunch.type.writable.WritableGroupedTableType<K,V>
- All Implemented Interfaces:
- PType<Pair<K,Iterable<V>>>
public class WritableGroupedTableType<K,V>
- extends PGroupedTableType<K,V>
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
WritableGroupedTableType
public WritableGroupedTableType(com.cloudera.crunch.type.writable.WritableTableType<K,V> tableType)
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>
Copyright © 2012. All Rights Reserved.