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

org.apache.crunch
Class GroupingOptions.Builder

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

Enclosing class:

GroupingOptions

public static class GroupingOptions.Builder
extends Object

Builder class for creating GroupingOptions instances.

Constructor Summary

GroupingOptions.Builder()

Method Summary

GroupingOptions	build()
GroupingOptions.Builder	conf(String confKey, String confValue)
GroupingOptions.Builder	groupingComparatorClass(Class<? extends org.apache.hadoop.io.RawComparator> groupingComparatorClass)
GroupingOptions.Builder	numReducers(int numReducers)
GroupingOptions.Builder	partitionerClass(Class<? extends org.apache.hadoop.mapreduce.Partitioner> partitionerClass)
GroupingOptions.Builder	requireSortedKeys()
GroupingOptions.Builder	sortComparatorClass(Class<? extends org.apache.hadoop.io.RawComparator> sortComparatorClass)
GroupingOptions.Builder	sourceTarget(SourceTarget<?> st) Deprecated.
GroupingOptions.Builder	sourceTargets(Collection<SourceTarget<?>> st)
GroupingOptions.Builder	sourceTargets(SourceTarget<?>... st)

Methods inherited from class java.lang.Object

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

Constructor Detail

GroupingOptions.Builder

public GroupingOptions.Builder()

Method Detail

partitionerClass

public GroupingOptions.Builder partitionerClass(Class<? extends org.apache.hadoop.mapreduce.Partitioner> partitionerClass)

groupingComparatorClass

public GroupingOptions.Builder groupingComparatorClass(Class<? extends org.apache.hadoop.io.RawComparator> groupingComparatorClass)

sortComparatorClass

public GroupingOptions.Builder sortComparatorClass(Class<? extends org.apache.hadoop.io.RawComparator> sortComparatorClass)

requireSortedKeys

public GroupingOptions.Builder requireSortedKeys()

numReducers

public GroupingOptions.Builder numReducers(int numReducers)

conf

public GroupingOptions.Builder conf(String confKey,
                                    String confValue)

sourceTarget

@Deprecated
public GroupingOptions.Builder sourceTarget(SourceTarget<?> st)

Deprecated.

sourceTargets

public GroupingOptions.Builder sourceTargets(SourceTarget<?>... st)

sourceTargets

public GroupingOptions.Builder sourceTargets(Collection<SourceTarget<?>> st)

build

public GroupingOptions build()