org.apache.hadoop.hbase.mapred

Class TableSplit

java.lang.Object

org.apache.hadoop.hbase.mapred.TableSplit

All Implemented Interfaces:

Comparable<TableSplit>, org.apache.hadoop.io.Writable, org.apache.hadoop.mapred.InputSplit

@InterfaceAudience.Public
public class TableSplit
extends Object
implements org.apache.hadoop.mapred.InputSplit, Comparable<TableSplit>

A table split corresponds to a key range [low, high)

Field Summary

Fields

Modifier and Type	Field and Description
private byte[]	m_endRow
private String	m_regionLocation
private byte[]	m_startRow
private TableName	m_tableName

Constructor Summary

Constructors

Constructor and Description
TableSplit() default constructor
TableSplit(byte[] tableName, byte[] startRow, byte[] endRow, String location)
TableSplit(TableName tableName, byte[] startRow, byte[] endRow, String location) Constructor

Method Summary

Modifier and Type	Method and Description
int	compareTo(TableSplit o)
boolean	equals(Object o)
byte[]	getEndRow()
long	getLength()
String[]	getLocations()
String	getRegionLocation()
byte[]	getStartRow()
TableName	getTable()
byte[]	getTableName()
int	hashCode()
void	readFields(DataInput in)
String	toString()
void	write(DataOutput out)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

m_tableName

private TableName m_tableName

m_startRow

private byte[] m_startRow

m_endRow

private byte[] m_endRow

m_regionLocation

private String m_regionLocation

Constructor Detail

TableSplit

public TableSplit()

default constructor

TableSplit

public TableSplit(TableName tableName,
                  byte[] startRow,
                  byte[] endRow,
                  String location)

Constructor

Parameters:

tableName -

startRow -

endRow -

location -

TableSplit

public TableSplit(byte[] tableName,
                  byte[] startRow,
                  byte[] endRow,
                  String location)

Method Detail

getTable

public TableName getTable()

Returns:

table name

getTableName

public byte[] getTableName()

Returns:

table name

getStartRow

public byte[] getStartRow()

Returns:

starting row key

getEndRow

public byte[] getEndRow()

Returns:

end row key

getRegionLocation

public String getRegionLocation()

Returns:

the region's hostname

getLocations

public String[] getLocations()

Specified by:

getLocations in interface org.apache.hadoop.mapred.InputSplit

getLength

public long getLength()

Specified by:

getLength in interface org.apache.hadoop.mapred.InputSplit

readFields

public void readFields(DataInput in)
                throws IOException

Specified by:

readFields in interface org.apache.hadoop.io.Writable

Throws:

IOException

write

public void write(DataOutput out)
           throws IOException

Specified by:

write in interface org.apache.hadoop.io.Writable

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object

compareTo

public int compareTo(TableSplit o)

Specified by:

compareTo in interface Comparable<TableSplit>

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object