Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-11436 Support start Row and stop Row in HBase Export (Ward Viaene)

This commit is contained in:
Ted Yu 2014-06-29 18:09:18 +00:00
parent c591a25f3c
commit dce2520828
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/Export.java
View File

@ -95,6 +95,13 @@ public class Export {
s.setTimeRange(startTime, endTime); s.setTimeRange(startTime, endTime);
// Set cache blocks // Set cache blocks
s.setCacheBlocks(false); s.setCacheBlocks(false);
// set Start and Stop row
if (conf.get(TableInputFormat.SCAN_ROW_START) != null) {
s.setStartRow(Bytes.toBytes(conf.get(TableInputFormat.SCAN_ROW_START)));
}
if (conf.get(TableInputFormat.SCAN_ROW_STOP) != null) {
s.setStopRow(Bytes.toBytes(conf.get(TableInputFormat.SCAN_ROW_STOP)));
}
// Set Scan Column Family // Set Scan Column Family
boolean raw = Boolean.parseBoolean(conf.get(RAW_SCAN)); boolean raw = Boolean.parseBoolean(conf.get(RAW_SCAN));
if (raw) { if (raw) {
@ -155,6 +162,8 @@ public class Export {
System.err.println(" to control/limit what is exported.."); System.err.println(" to control/limit what is exported..");
System.err.println(" -D " + TableInputFormat.SCAN_COLUMN_FAMILY + "=<familyName>"); System.err.println(" -D " + TableInputFormat.SCAN_COLUMN_FAMILY + "=<familyName>");
System.err.println(" -D " + RAW_SCAN + "=true"); System.err.println(" -D " + RAW_SCAN + "=true");
System.err.println(" -D " + TableInputFormat.SCAN_ROW_START + "=<ROWSTART>");
System.err.println(" -D " + TableInputFormat.SCAN_ROW_STOP + "=<ROWSTOP>");
System.err.println("For performance consider the following properties:\n" System.err.println("For performance consider the following properties:\n"
+ " -Dhbase.client.scanner.caching=100\n" + " -Dhbase.client.scanner.caching=100\n"
+ " -Dmapreduce.map.speculative=false\n" + " -Dmapreduce.map.speculative=false\n"