org.apache.hadoop.mapreduce.lib.db

类 DataDrivenDBInputFormat.DataDrivenDBInputSplit

java.lang.Object

org.apache.hadoop.mapreduce.InputSplit

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

org.apache.hadoop.mapreduce.lib.db.DataDrivenDBInputFormat.DataDrivenDBInputSplit

所有已实现的接口:

Writable

封闭类:

DataDrivenDBInputFormat<T extends DBWritable>

@InterfaceStability.Evolving
public static class DataDrivenDBInputFormat.DataDrivenDBInputSplit
extends DBInputFormat.DBInputSplit

A InputSplit that spans a set of rows

构造器概要

构造器

构造器和说明
DataDrivenDBInputFormat.DataDrivenDBInputSplit() Default Constructor
DataDrivenDBInputFormat.DataDrivenDBInputSplit(String lower, String upper) Convenience Constructor

方法概要

方法

限定符和类型	方法和说明
long	getLength() Get the size of the split, so that the input splits can be sorted by size.
String	getLowerClause()
String	getUpperClause()
void	readFields(DataInput input) Deserialize the fields of this object from in.
void	write(DataOutput output) Serialize the fields of this object to out.

从类继承的方法 org.apache.hadoop.mapreduce.lib.db.DBInputFormat.DBInputSplit

getEnd, getLocations, getStart

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

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

构造器详细资料

DataDrivenDBInputFormat.DataDrivenDBInputSplit

public DataDrivenDBInputFormat.DataDrivenDBInputSplit()

Default Constructor

DataDrivenDBInputFormat.DataDrivenDBInputSplit

public DataDrivenDBInputFormat.DataDrivenDBInputSplit(String lower,
                                              String upper)

Convenience Constructor

参数:

lower - the string to be put in the WHERE clause to guard on the 'lower' end

upper - the string to be put in the WHERE clause to guard on the 'upper' end

方法详细资料

getLength

public long getLength()
               throws IOException

从类复制的说明: InputSplit

Get the size of the split, so that the input splits can be sorted by size.

覆盖:

getLength 在类中 DBInputFormat.DBInputSplit

返回:

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

覆盖:

readFields 在类中 DBInputFormat.DBInputSplit

参数:

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

覆盖:

write 在类中 DBInputFormat.DBInputSplit

参数:

output - DataOuput to serialize this object into.

抛出:

IOException

getLowerClause

public String getLowerClause()

getUpperClause

public String getUpperClause()