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

org.apache.crunch.util
Class PartitionUtils

java.lang.Object
  org.apache.crunch.util.PartitionUtils

public class PartitionUtils
extends Object

Field Summary

static String	BYTES_PER_REDUCE_TASK
static long	DEFAULT_BYTES_PER_REDUCE_TASK

Constructor Summary

PartitionUtils()

Method Summary

static <T> int	getRecommendedPartitions(PCollection<T> pcollection)
static <T> int	getRecommendedPartitions(PCollection<T> pcollection, org.apache.hadoop.conf.Configuration conf)

Methods inherited from class java.lang.Object

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

Field Detail

BYTES_PER_REDUCE_TASK

public static final String BYTES_PER_REDUCE_TASK

See Also:

Constant Field Values

DEFAULT_BYTES_PER_REDUCE_TASK

public static final long DEFAULT_BYTES_PER_REDUCE_TASK

See Also:

Constant Field Values

Constructor Detail

PartitionUtils

public PartitionUtils()

Method Detail

getRecommendedPartitions

public static <T> int getRecommendedPartitions(PCollection<T> pcollection)

getRecommendedPartitions

public static <T> int getRecommendedPartitions(PCollection<T> pcollection,
                                               org.apache.hadoop.conf.Configuration conf)