This project has retired. For details please refer to its
Attic page.
PartitionUtils (Apache Crunch 0.7.0 API)
org.apache.crunch.util
Class PartitionUtils
java.lang.Object
org.apache.crunch.util.PartitionUtils
public class PartitionUtils
- extends Object
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
PartitionUtils
public PartitionUtils()
getRecommendedPartitions
public static <T> int getRecommendedPartitions(PCollection<T> pcollection)
getRecommendedPartitions
public static <T> int getRecommendedPartitions(PCollection<T> pcollection,
org.apache.hadoop.conf.Configuration conf)
Copyright © 2013 The Apache Software Foundation. All Rights Reserved.