org.apache.hadoop.mapred.join

クラス CompositeInputSplit

java.lang.Object

org.apache.hadoop.mapred.join.CompositeInputSplit

すべての実装されたインタフェース:

Writable, InputSplit

@InterfaceAudience.Public
 @InterfaceStability.Stable
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.