@InterfaceAudience.Public @InterfaceStability.Evolving public class TezGroupedSplitsInputFormat<K,V> extends Object implements org.apache.hadoop.mapred.InputFormat<K,V>, org.apache.hadoop.conf.Configurable
Constructor and Description |
---|
TezGroupedSplitsInputFormat() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.conf.Configuration |
getConf() |
org.apache.hadoop.mapred.RecordReader<K,V> |
getRecordReader(org.apache.hadoop.mapred.InputSplit split,
org.apache.hadoop.mapred.JobConf job,
org.apache.hadoop.mapred.Reporter reporter) |
org.apache.hadoop.mapred.InputSplit[] |
getSplits(org.apache.hadoop.mapred.JobConf job,
int numSplits) |
void |
setConf(org.apache.hadoop.conf.Configuration conf) |
void |
setDesiredNumberOfSplits(int num) |
void |
setInputFormat(org.apache.hadoop.mapred.InputFormat<K,V> wrappedInputFormat) |
void |
setSplitLocationProvider(org.apache.hadoop.mapred.split.SplitLocationProvider locationProvider) |
void |
setSplitSizeEstimator(org.apache.hadoop.mapred.split.SplitSizeEstimator estimator) |
public void setInputFormat(org.apache.hadoop.mapred.InputFormat<K,V> wrappedInputFormat)
public void setSplitSizeEstimator(org.apache.hadoop.mapred.split.SplitSizeEstimator estimator)
public void setSplitLocationProvider(org.apache.hadoop.mapred.split.SplitLocationProvider locationProvider)
public void setDesiredNumberOfSplits(int num)
public org.apache.hadoop.mapred.InputSplit[] getSplits(org.apache.hadoop.mapred.JobConf job, int numSplits) throws IOException
getSplits
in interface org.apache.hadoop.mapred.InputFormat<K,V>
IOException
public org.apache.hadoop.mapred.RecordReader<K,V> getRecordReader(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.Reporter reporter) throws IOException
getRecordReader
in interface org.apache.hadoop.mapred.InputFormat<K,V>
IOException
public void setConf(org.apache.hadoop.conf.Configuration conf)
setConf
in interface org.apache.hadoop.conf.Configurable
public org.apache.hadoop.conf.Configuration getConf()
getConf
in interface org.apache.hadoop.conf.Configurable
Copyright © 2024 Apache Software Foundation. All rights reserved.