org.apache.crunch
Class GroupingOptions
java.lang.Object
org.apache.crunch.GroupingOptions
- All Implemented Interfaces:
- Serializable
public class GroupingOptions
- extends Object
- implements Serializable
Options that can be passed to a groupByKey
operation in order to
exercise finer control over how the partitioning, grouping, and sorting of
keys is performed.
- See Also:
- Serialized Form
getNumReducers
public int getNumReducers()
requireSortedKeys
public boolean requireSortedKeys()
getSortComparatorClass
public Class<? extends org.apache.hadoop.io.RawComparator> getSortComparatorClass()
getGroupingComparatorClass
public Class<? extends org.apache.hadoop.io.RawComparator> getGroupingComparatorClass()
getPartitionerClass
public Class<? extends org.apache.hadoop.mapreduce.Partitioner> getPartitionerClass()
getSourceTargets
public Set<SourceTarget<?>> getSourceTargets()
configure
public void configure(org.apache.hadoop.mapreduce.Job job)
isCompatibleWith
public boolean isCompatibleWith(GroupingOptions other)
builder
public static GroupingOptions.Builder builder()
Copyright © 2014 The Apache Software Foundation. All Rights Reserved.