org.apache.hadoop.mapreduce.lib.db

类 DBInputFormat.DBInputSplit

java.lang.Object

org.apache.hadoop.mapreduce.InputSplit

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

所有已实现的接口:

Writable

直接已知子类:

DataDrivenDBInputFormat.DataDrivenDBInputSplit

封闭类:

DBInputFormat<T extends DBWritable>

@InterfaceStability.Evolving
public static class DBInputFormat.DBInputSplit
extends InputSplit
implements Writable

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 size of the split, so that the input splits can be sorted by size.
String[]	getLocations() Get the list of nodes by name where the data for the split would be local.
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 nodes by name where the data for the split would be local. The locations do not need to be serialized.

指定者:

getLocations 在类中 InputSplit

返回:

a new array of the node nodes.

抛出:

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 size of the split, so that the input splits can be sorted by size.

指定者:

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