@InterfaceAudience.Public @InterfaceStability.Evolving public class TezGroupedSplit extends Object implements org.apache.hadoop.mapred.InputSplit, org.apache.hadoop.conf.Configurable
Constructor and Description |
---|
TezGroupedSplit() |
TezGroupedSplit(int numSplits,
String wrappedInputFormatName,
String[] locations) |
TezGroupedSplit(int numSplits,
String wrappedInputFormatName,
String[] locations,
String rack) |
Modifier and Type | Method and Description |
---|---|
void |
addSplit(org.apache.hadoop.mapred.InputSplit split) |
org.apache.hadoop.conf.Configuration |
getConf() |
List<org.apache.hadoop.mapred.InputSplit> |
getGroupedSplits() |
long |
getLength() |
String[] |
getLocations() |
String |
getRack() |
void |
readFields(DataInput in) |
void |
setConf(org.apache.hadoop.conf.Configuration conf) |
void |
write(DataOutput out) |
public TezGroupedSplit()
public TezGroupedSplit(int numSplits, String wrappedInputFormatName, String[] locations, String rack)
public List<org.apache.hadoop.mapred.InputSplit> getGroupedSplits()
public void addSplit(org.apache.hadoop.mapred.InputSplit split)
public void write(DataOutput out) throws IOException
write
in interface org.apache.hadoop.io.Writable
IOException
public void readFields(DataInput in) throws IOException
readFields
in interface org.apache.hadoop.io.Writable
IOException
public long getLength() throws IOException
getLength
in interface org.apache.hadoop.mapred.InputSplit
IOException
public String[] getLocations() throws IOException
getLocations
in interface org.apache.hadoop.mapred.InputSplit
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
public String getRack()
Copyright © 2015 Apache Software Foundation. All rights reserved.