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

static class	JoinUtils.AvroIndexedRecordPartitioner<K,V>
static class	JoinUtils.AvroPairGroupingComparator<T>
static class	JoinUtils.TupleWritableComparator
static class	JoinUtils.TupleWritablePartitioner

Constructor Summary

JoinUtils()

Method Summary

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)