com.cloudera.crunch.lib
Class JoinUtils

java.lang.Object
  com.cloudera.crunch.lib.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
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

clone, equals, finalize, 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)