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
PGroupedTableType
public PGroupedTableType(PTableType<K,V> tableType)
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>>>
Copyright © 2014 The Apache Software Foundation. All Rights Reserved.