org.apache.hadoop.mapred.split

Class TezMapredSplitsGrouper

java.lang.Object

org.apache.hadoop.mapred.split.TezMapredSplitsGrouper

@InterfaceAudience.Public
@InterfaceStability.Evolving
public class TezMapredSplitsGrouper
extends Object

A Helper that provides grouping logic to group InputSplits using various parameters. A TezGroupedSplit is used to wrap the real InputSplits in a group.

Constructor Summary

Constructors

Constructor and Description
TezMapredSplitsGrouper()

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.mapred.InputSplit[]	getGroupedSplits(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapred.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

TezMapredSplitsGrouper

public TezMapredSplitsGrouper()

Method Detail

getGroupedSplits

public org.apache.hadoop.mapred.InputSplit[] getGroupedSplits(org.apache.hadoop.conf.Configuration conf,
                                                     org.apache.hadoop.mapred.InputSplit[] originalSplits,
                                                     int desiredNumSplits,
                                                     String wrappedInputFormatName)
                                                       throws IOException

Throws:

IOException