org.apache.crunch.lib.join

Class JoinUtils

java.lang.Object

org.apache.crunch.lib.join.JoinUtils

public class JoinUtils
extends Object

Utilities that are useful in joining multiple data sets via a MapReduce.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JoinUtils.AvroIndexedRecordPartitioner
static class	JoinUtils.AvroPairGroupingComparator<T>
static class	JoinUtils.TupleWritableComparator
static class	JoinUtils.TupleWritablePartitioner

Constructor Summary

Constructors

Constructor and Description
JoinUtils()

Method Summary

Modifier and Type	Method and Description
static Class<? extends org.apache.hadoop.io.RawComparator>	getGroupingComparator(PTypeFamily typeFamily)
static Class<? extends org.apache.hadoop.mapreduce.Partitioner>	getPartitionerClass(PTypeFamily typeFamily)

Methods inherited from class java.lang.Object

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

Constructor Detail

JoinUtils

public JoinUtils()

Method Detail

getPartitionerClass

public static Class<? extends org.apache.hadoop.mapreduce.Partitioner> getPartitionerClass(PTypeFamily typeFamily)

getGroupingComparator

public static Class<? extends org.apache.hadoop.io.RawComparator> getGroupingComparator(PTypeFamily typeFamily)