|
@@ -1271,23 +1271,7 @@ public class HRegionServer implements HConstants, HRegionInterface, Runnable {
|
|
|
/** {@inheritDoc} */
|
|
|
public MapWritable getRow(final Text regionName, final Text row)
|
|
|
throws IOException {
|
|
|
-
|
|
|
- checkOpen();
|
|
|
- requestCount.incrementAndGet();
|
|
|
- try {
|
|
|
- HRegion region = getRegion(regionName);
|
|
|
- MapWritable result = new MapWritable();
|
|
|
- Map<Text, byte[]> map = region.getFull(row);
|
|
|
- for (Map.Entry<Text, byte []> es: map.entrySet()) {
|
|
|
- result.put(new HStoreKey(row, es.getKey()),
|
|
|
- new ImmutableBytesWritable(es.getValue()));
|
|
|
- }
|
|
|
- return result;
|
|
|
-
|
|
|
- } catch (IOException e) {
|
|
|
- checkFileSystem();
|
|
|
- throw e;
|
|
|
- }
|
|
|
+ return getRow(regionName, row, HConstants.LATEST_TIMESTAMP);
|
|
|
}
|
|
|
|
|
|
/** {@inheritDoc} */
|
|
@@ -1299,7 +1283,7 @@ public class HRegionServer implements HConstants, HRegionInterface, Runnable {
|
|
|
try {
|
|
|
HRegion region = getRegion(regionName);
|
|
|
MapWritable result = new MapWritable();
|
|
|
- Map<Text, byte[]> map = region.getFull(row);
|
|
|
+ Map<Text, byte[]> map = region.getFull(row, ts);
|
|
|
for (Map.Entry<Text, byte []> es: map.entrySet()) {
|
|
|
result.put(new HStoreKey(row, es.getKey()),
|
|
|
new ImmutableBytesWritable(es.getValue()));
|