|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
public interface HRegionInterface
Clients interact with HRegionServers using a handle to the HRegionInterface.
| Field Summary | |
|---|---|
static long |
versionID
Protocol version. |
| Method Summary | |
|---|---|
void |
batchUpdate(byte[] regionName,
BatchUpdate b,
long lockId)
Applies a batch of updates via one RPC |
void |
close(long scannerId)
Close a scanner |
void |
deleteAll(byte[] regionName,
byte[] row,
byte[] column,
long timestamp,
long lockId)
Delete all cells that match the passed row and column and whose timestamp is equal-to or older than the passed timestamp. |
void |
deleteAll(byte[] regionName,
byte[] row,
long timestamp,
long lockId)
Delete all cells that match the passed row and whose timestamp is equal-to or older than the passed timestamp. |
void |
deleteFamily(byte[] regionName,
byte[] row,
byte[] family,
long timestamp,
long lockId)
Delete all cells for a row with matching column family with timestamps less than or equal to timestamp. |
Cell[] |
get(byte[] regionName,
byte[] row,
byte[] column,
long timestamp,
int numVersions)
Get the specified number of versions of the specified row and column with the specified timestamp. |
RowResult |
getClosestRowBefore(byte[] regionName,
byte[] row)
Return all the data for the row that matches row exactly, or the one that immediately preceeds it. |
HRegionInfo |
getRegionInfo(byte[] regionName)
Get metainfo about an HRegion |
RowResult |
getRow(byte[] regionName,
byte[] row,
byte[][] columns,
long ts,
long lockId)
Get selected columns for the specified row at a given timestamp. |
long |
lockRow(byte[] regionName,
byte[] row)
Opens a remote row lock. |
RowResult |
next(long scannerId)
Get the next set of values |
long |
openScanner(byte[] regionName,
byte[][] columns,
byte[] startRow,
long timestamp,
RowFilterInterface filter)
Opens a remote scanner with a RowFilter. |
void |
unlockRow(byte[] regionName,
long lockId)
Releases a remote row lock. |
| Methods inherited from interface org.apache.hadoop.ipc.VersionedProtocol |
|---|
getProtocolVersion |
| Field Detail |
|---|
static final long versionID
| Method Detail |
|---|
HRegionInfo getRegionInfo(byte[] regionName)
throws NotServingRegionException
regionName - name of the region
NotServingRegionException
Cell[] get(byte[] regionName,
byte[] row,
byte[] column,
long timestamp,
int numVersions)
throws IOException
regionName - region namerow - row keycolumn - column keytimestamp - timestampnumVersions - number of versions to return
IOException
RowResult getClosestRowBefore(byte[] regionName,
byte[] row)
throws IOException
regionName - region namerow - row key
IOException
RowResult getRow(byte[] regionName,
byte[] row,
byte[][] columns,
long ts,
long lockId)
throws IOException
regionName - region namerow - row keycolumns - columns to getts - time stamplockId - lock id
IOException
void batchUpdate(byte[] regionName,
BatchUpdate b,
long lockId)
throws IOException
regionName - name of the region to updateb - BatchUpdatelockId - lock id
IOException
void deleteAll(byte[] regionName,
byte[] row,
byte[] column,
long timestamp,
long lockId)
throws IOException
regionName - region namerow - row keycolumn - column keytimestamp - Delete all entries that have this timestamp or olderlockId - lock id
IOException
void deleteAll(byte[] regionName,
byte[] row,
long timestamp,
long lockId)
throws IOException
regionName - region namerow - row keytimestamp - Delete all entries that have this timestamp or olderlockId - lock id
IOException
void deleteFamily(byte[] regionName,
byte[] row,
byte[] family,
long timestamp,
long lockId)
throws IOException
regionName - The name of the region to operate onrow - The row to operate onfamily - The column family to matchtimestamp - Timestamp to matchlockId - lock id
IOException
long openScanner(byte[] regionName,
byte[][] columns,
byte[] startRow,
long timestamp,
RowFilterInterface filter)
throws IOException
regionName - name of region to scancolumns - columns to scan. If column name is a column family, all
columns of the specified column family are returned. Its also possible
to pass a regex for column family name. A column name is judged to be
regex if it contains at least one of the following characters:
\+|^&*$[]]}{)(.startRow - starting row to scantimestamp - only return values whose timestamp is <= this valuefilter - RowFilter for filtering results at the row-level.
IOException
RowResult next(long scannerId)
throws IOException
scannerId - clientId passed to openScanner
IOException
void close(long scannerId)
throws IOException
scannerId - the scanner id returned by openScanner
IOException
long lockRow(byte[] regionName,
byte[] row)
throws IOException
regionName - name of regionrow - row to lock
IOException
void unlockRow(byte[] regionName,
long lockId)
throws IOException
regionName - lockId - the lock id returned by lockRow
IOException
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||