public class TableSplit extends InputSplit implements java.lang.Comparable<TableSplit>
Modifier and Type | Field and Description |
---|---|
static Logger |
LOG
Deprecated.
LOG variable would be made private. fix in hbase 3.0
|
Constructor and Description |
---|
TableSplit()
Default constructor.
|
TableSplit(TableName tableName,
byte[] startRow,
byte[] endRow,
java.lang.String location)
Creates a new instance without a scanner.
|
TableSplit(TableName tableName,
byte[] startRow,
byte[] endRow,
java.lang.String location,
long length)
Creates a new instance without a scanner.
|
TableSplit(TableName tableName,
Scan scan,
byte[] startRow,
byte[] endRow,
java.lang.String location)
Creates a new instance while assigning all variables.
|
TableSplit(TableName tableName,
Scan scan,
byte[] startRow,
byte[] endRow,
java.lang.String location,
long length)
Creates a new instance while assigning all variables.
|
TableSplit(TableName tableName,
Scan scan,
byte[] startRow,
byte[] endRow,
java.lang.String location,
java.lang.String encodedRegionName,
long length)
Creates a new instance while assigning all variables.
|
Modifier and Type | Method and Description |
---|---|
int |
compareTo(TableSplit split)
Compares this split against the given one.
|
boolean |
equals(java.lang.Object o) |
java.lang.String |
getEncodedRegionName()
Returns the region's encoded name.
|
byte[] |
getEndRow()
Returns the end row.
|
long |
getLength()
Returns the length of the split.
|
java.lang.String[] |
getLocations()
Returns the region's location as an array.
|
java.lang.String |
getRegionLocation()
Returns the region location.
|
Scan |
getScan()
Returns a Scan object from the stored string representation.
|
byte[] |
getStartRow()
Returns the start row.
|
TableName |
getTable()
Returns the table name.
|
byte[] |
getTableName()
Returns the table name converted to a byte array.
|
int |
hashCode() |
void |
readFields(java.io.DataInput in)
Reads the values of each field.
|
java.lang.String |
toString()
Returns the details about this instance as a string.
|
void |
write(java.io.DataOutput out)
Writes the field values to the output.
|
@Deprecated public static final Logger LOG
public TableSplit()
public TableSplit(TableName tableName, Scan scan, byte[] startRow, byte[] endRow, java.lang.String location)
tableName
- The name of the current table.scan
- The scan associated with this split.startRow
- The start row of the split.endRow
- The end row of the split.location
- The location of the region.public TableSplit(TableName tableName, Scan scan, byte[] startRow, byte[] endRow, java.lang.String location, long length)
tableName
- The name of the current table.scan
- The scan associated with this split.startRow
- The start row of the split.endRow
- The end row of the split.location
- The location of the region.public TableSplit(TableName tableName, Scan scan, byte[] startRow, byte[] endRow, java.lang.String location, java.lang.String encodedRegionName, long length)
tableName
- The name of the current table.scan
- The scan associated with this split.startRow
- The start row of the split.endRow
- The end row of the split.encodedRegionName
- The region ID.location
- The location of the region.public TableSplit(TableName tableName, byte[] startRow, byte[] endRow, java.lang.String location)
tableName
- The name of the current table.startRow
- The start row of the split.endRow
- The end row of the split.location
- The location of the region.public TableSplit(TableName tableName, byte[] startRow, byte[] endRow, java.lang.String location, long length)
tableName
- The name of the current table.startRow
- The start row of the split.endRow
- The end row of the split.location
- The location of the region.length
- Size of region in bytespublic Scan getScan() throws java.io.IOException
java.io.IOException
public byte[] getTableName()
getTable()
public TableName getTable()
public byte[] getStartRow()
public byte[] getEndRow()
public java.lang.String getRegionLocation()
public java.lang.String[] getLocations()
org.apache.hadoop.mapreduce.InputSplit#getLocations()
public java.lang.String getEncodedRegionName()
public long getLength()
org.apache.hadoop.mapreduce.InputSplit#getLength()
public void readFields(java.io.DataInput in) throws java.io.IOException
in
- The input to read from.java.io.IOException
- When reading the input fails.public void write(java.io.DataOutput out) throws java.io.IOException
out
- The output to write to.java.io.IOException
- When writing the values to the output fails.public java.lang.String toString()
Object.toString()
public int compareTo(TableSplit split)
compareTo
in interface java.lang.Comparable<TableSplit>
split
- The split to compare to.Comparable.compareTo(java.lang.Object)
public boolean equals(java.lang.Object o)
public int hashCode()