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

org.apache.crunch
Class GroupingOptions

java.lang.Object
  org.apache.crunch.GroupingOptions

public class GroupingOptions
extends Object

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.

Nested Class Summary

static class

GroupingOptions.Builder Builder class for creating GroupingOptions instances.

Method Summary

static GroupingOptions.Builder	builder()
void	configure(org.apache.hadoop.mapreduce.Job job)
Class<? extends org.apache.hadoop.io.RawComparator>	getGroupingComparatorClass()
int	getNumReducers()
Class<? extends org.apache.hadoop.mapreduce.Partitioner>	getPartitionerClass()
Class<? extends org.apache.hadoop.io.RawComparator>	getSortComparatorClass()
Set<SourceTarget<?>>	getSourceTargets()
boolean	isCompatibleWith(GroupingOptions other)

Methods inherited from class java.lang.Object

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

Method Detail

getNumReducers

public int getNumReducers()

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()