org.apache.hadoop.mapred.join

类 CompositeInputSplit

java.lang.Object

org.apache.hadoop.mapred.join.CompositeInputSplit

所有已实现的接口:

Writable, InputSplit

public class CompositeInputSplit
extends Object
implements InputSplit

This InputSplit contains a set of child InputSplits. Any InputSplit inserted into this collection must have a public default constructor.

构造器概要

构造器

构造器和说明
CompositeInputSplit()
CompositeInputSplit(int capacity)

方法概要

方法

限定符和类型	方法和说明
void	add(InputSplit s) Add an InputSplit to this collection.
InputSplit	get(int i) Get ith child InputSplit.
long	getLength() Return the aggregate length of all child InputSplits currently added.
long	getLength(int i) Get the length of ith child InputSplit.
String[]	getLocation(int i) getLocations from ith InputSplit.
String[]	getLocations() Collect a set of hosts from all child InputSplits.
void	readFields(DataInput in) Deserialize the fields of this object from in.
void	write(DataOutput out) Write splits in the following format.

从类继承的方法 java.lang.Object

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

构造器详细资料

CompositeInputSplit

public CompositeInputSplit()

CompositeInputSplit

public CompositeInputSplit(int capacity)

方法详细资料

add

public void add(InputSplit s)
         throws IOException

Add an InputSplit to this collection.

抛出:

IOException - If capacity was not specified during construction or if capacity has been reached.

get

public InputSplit get(int i)

Get ith child InputSplit.

getLength

public long getLength()
               throws IOException

Return the aggregate length of all child InputSplits currently added.

指定者:

getLength 在接口中 InputSplit

返回:

the number of bytes in the input split.

抛出:

IOException

getLength

public long getLength(int i)
               throws IOException

Get the length of ith child InputSplit.

抛出:

IOException

getLocations

public String[] getLocations()
                      throws IOException

Collect a set of hosts from all child InputSplits.

指定者:

getLocations 在接口中 InputSplit

返回:

list of hostnames where data of the InputSplit is located as an array of Strings.

抛出:

IOException

getLocation

public String[] getLocation(int i)
                     throws IOException

getLocations from ith InputSplit.

抛出:

IOException

write

public void write(DataOutput out)
           throws IOException

Write splits in the following format. <count><class1><class2>...<classn><split1><split2>...<splitn>

指定者:

write 在接口中 Writable

参数:

out - DataOuput to serialize this object into.

抛出:

IOException

readFields

public void readFields(DataInput in)
                throws IOException

Deserialize the fields of this object from in.

For efficiency, implementations should attempt to re-use storage in the existing object where possible.

指定者:

readFields 在接口中 Writable

参数:

in - DataInput to deseriablize this object from.

抛出:

IOException - If the child InputSplit cannot be read, typically for faliing access checks.