This project has retired. For details please refer to its Attic page.

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)