org.apache.hadoop.mapred.lib.db

类 DBInputFormat.DBInputSplit

java.lang.Object

org.apache.hadoop.mapred.lib.db.DBInputFormat.DBInputSplit

所有已实现的接口:

Writable, InputSplit

封闭类:

DBInputFormat<T extends DBWritable>

protected static class DBInputFormat.DBInputSplit
extends Object
implements InputSplit

A InputSplit that spans a set of rows

构造器概要

构造器

构造器和说明
DBInputFormat.DBInputSplit() Default Constructor
DBInputFormat.DBInputSplit(long start, long end) Convenience Constructor

方法概要

方法

限定符和类型	方法和说明
long	getEnd()
long	getLength() Get the total number of bytes in the data of the InputSplit.
String[]	getLocations() Get the list of hostnames where the input split is located.
long	getStart()
void	readFields(DataInput input) Deserialize the fields of this object from in.
void	write(DataOutput output) Serialize the fields of this object to out.

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

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

构造器详细资料

DBInputFormat.DBInputSplit

public DBInputFormat.DBInputSplit()

Default Constructor

DBInputFormat.DBInputSplit

public DBInputFormat.DBInputSplit(long start,
                          long end)

Convenience Constructor

参数:

start - the index of the first row to select

end - the index of the last row to select

方法详细资料

getLocations

public String[] getLocations()
                      throws IOException

Get the list of hostnames where the input split is located.

指定者:

getLocations 在接口中 InputSplit

返回:

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

抛出:

IOException

getStart

public long getStart()

返回:

The index of the first row to select

getEnd

public long getEnd()

返回:

The index of the last row to select

getLength

public long getLength()
               throws IOException

从接口复制的说明: InputSplit

Get the total number of bytes in the data of the InputSplit.

指定者:

getLength 在接口中 InputSplit

返回:

The total row count in this split

抛出:

IOException

readFields

public void readFields(DataInput input)
                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

参数:

input - DataInput to deseriablize this object from.

抛出:

IOException

write

public void write(DataOutput output)
           throws IOException

Serialize the fields of this object to out.

指定者:

write 在接口中 Writable

参数:

output - DataOuput to serialize this object into.

抛出:

IOException