org.apache.hadoop.mapreduce.split
Class TezMapReduceSplitsGrouper

java.lang.Object
  org.apache.hadoop.mapreduce.split.TezMapReduceSplitsGrouper

public class TezMapReduceSplitsGrouper
extends Object

Constructor Summary

TezMapReduceSplitsGrouper()

Method Summary

List<org.apache.hadoop.mapreduce.InputSplit>

getGroupedSplits(org.apache.hadoop.conf.Configuration conf, List<org.apache.hadoop.mapreduce.InputSplit> originalSplits, int desiredNumSplits, String wrappedInputFormatName)

Methods inherited from class java.lang.Object

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

Constructor Detail

TezMapReduceSplitsGrouper

public TezMapReduceSplitsGrouper()

Method Detail

getGroupedSplits

public List<org.apache.hadoop.mapreduce.InputSplit> getGroupedSplits(org.apache.hadoop.conf.Configuration conf,
                                                                     List<org.apache.hadoop.mapreduce.InputSplit> originalSplits,
                                                                     int desiredNumSplits,
                                                                     String wrappedInputFormatName)
                                                              throws IOException,
                                                                     InterruptedException

Throws:

IOException

InterruptedException