org.apache.tez.mapreduce.lib

Class MRInputUtils

java.lang.Object

org.apache.tez.mapreduce.lib.MRInputUtils

@InterfaceAudience.Private
public class MRInputUtils
extends Object

Helper methods for InputFormat based Inputs. Private to Tez.

Constructor Summary

Constructors

Constructor and Description
MRInputUtils()

Method Summary

Methods

Modifier and Type	Method and Description
static org.apache.hadoop.mapreduce.InputSplit	getNewSplitDetailsFromDisk(org.apache.hadoop.mapreduce.split.JobSplit.TaskSplitIndex splitMetaInfo, org.apache.hadoop.mapred.JobConf jobConf, org.apache.tez.common.counters.TezCounter splitBytesCounter)
static org.apache.hadoop.mapreduce.InputSplit	getNewSplitDetailsFromEvent(MRRuntimeProtos.MRSplitProto splitProto, org.apache.hadoop.conf.Configuration conf)
static org.apache.hadoop.mapred.InputSplit	getOldSplitDetailsFromDisk(org.apache.hadoop.mapreduce.split.JobSplit.TaskSplitIndex splitMetaInfo, org.apache.hadoop.mapred.JobConf jobConf, org.apache.tez.common.counters.TezCounter splitBytesCounter)
static org.apache.hadoop.mapred.InputSplit	getOldSplitDetailsFromEvent(MRRuntimeProtos.MRSplitProto splitProto, org.apache.hadoop.conf.Configuration conf)
static org.apache.hadoop.mapreduce.split.JobSplit.TaskSplitMetaInfo[]	readSplits(org.apache.hadoop.conf.Configuration conf)

Methods inherited from class java.lang.Object

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

Constructor Detail

MRInputUtils

public MRInputUtils()

Method Detail

readSplits

public static org.apache.hadoop.mapreduce.split.JobSplit.TaskSplitMetaInfo[] readSplits(org.apache.hadoop.conf.Configuration conf)
                                                                                 throws IOException

Throws:

IOException

getNewSplitDetailsFromEvent

public static org.apache.hadoop.mapreduce.InputSplit getNewSplitDetailsFromEvent(MRRuntimeProtos.MRSplitProto splitProto,
                                                                 org.apache.hadoop.conf.Configuration conf)
                                                                          throws IOException

Throws:

IOException

getNewSplitDetailsFromDisk

public static org.apache.hadoop.mapreduce.InputSplit getNewSplitDetailsFromDisk(org.apache.hadoop.mapreduce.split.JobSplit.TaskSplitIndex splitMetaInfo,
                                                                org.apache.hadoop.mapred.JobConf jobConf,
                                                                org.apache.tez.common.counters.TezCounter splitBytesCounter)
                                                                         throws IOException

Throws:

IOException

getOldSplitDetailsFromDisk

public static org.apache.hadoop.mapred.InputSplit getOldSplitDetailsFromDisk(org.apache.hadoop.mapreduce.split.JobSplit.TaskSplitIndex splitMetaInfo,
                                                             org.apache.hadoop.mapred.JobConf jobConf,
                                                             org.apache.tez.common.counters.TezCounter splitBytesCounter)
                                                                      throws IOException

Throws:

IOException

getOldSplitDetailsFromEvent

@InterfaceAudience.Private
public static org.apache.hadoop.mapred.InputSplit getOldSplitDetailsFromEvent(MRRuntimeProtos.MRSplitProto splitProto,
                                                                                        org.apache.hadoop.conf.Configuration conf)
                                                                       throws IOException

Throws:

IOException