org.apache.crunch.lib.join
Class JoinUtils

java.lang.Object
  extended by 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)


Copyright © 2012 The Apache Software Foundation. All Rights Reserved.