org.apache.hadoop.mapreduce.lib.join

クラス CompositeInputSplit

java.lang.Object

org.apache.hadoop.mapreduce.InputSplit

org.apache.hadoop.mapreduce.lib.join.CompositeInputSplit

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

Writable

@InterfaceAudience.Public
 @InterfaceStability.Stable
public class CompositeInputSplit
extends InputSplit
implements Writable

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.

クラスから継承されたメソッド org.apache.hadoop.mapreduce.InputSplit

getLocationInfo

クラスから継承されたメソッド 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,
                InterruptedException

Add an InputSplit to this collection.

例外:

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

InterruptedException

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 split

例外:

IOException

getLength

public long getLength(int i)
               throws IOException,
                      InterruptedException

Get the length of ith child InputSplit.

例外:

IOException

InterruptedException

getLocations

public String[] getLocations()
                      throws IOException,
                             InterruptedException

Collect a set of hosts from all child InputSplits.

定義:

getLocations クラス内 InputSplit

戻り値:

a new array of the node nodes.

例外:

IOException

InterruptedException

getLocation

public String[] getLocation(int i)
                     throws IOException,
                            InterruptedException

getLocations from ith InputSplit.

例外:

IOException

InterruptedException

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 failing access checks.