From 3618d9db1b4fff554e186e279cff08c473c995de Mon Sep 17 00:00:00 2001 From: rahulgidwani Date: Fri, 13 Feb 2015 13:16:21 -0800 Subject: [PATCH] HBASE-13043 - backport of HBASE-11436 --- src/main/java/org/apache/hadoop/hbase/mapreduce/Export.java | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git src/main/java/org/apache/hadoop/hbase/mapreduce/Export.java src/main/java/org/apache/hadoop/hbase/mapreduce/Export.java index 2c53f6d..bc1d326 100644 --- src/main/java/org/apache/hadoop/hbase/mapreduce/Export.java +++ src/main/java/org/apache/hadoop/hbase/mapreduce/Export.java @@ -115,6 +115,13 @@ public class Export { s.setTimeRange(startTime, endTime); // Set cache blocks 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 boolean raw = Boolean.parseBoolean(conf.get(RAW_SCAN)); if (raw) { @@ -166,6 +173,8 @@ public class Export { System.err.println(" to control/limit what is exported.."); System.err.println(" -D " + TableInputFormat.SCAN_COLUMN_FAMILY + "="); System.err.println(" -D " + RAW_SCAN + "=true"); + System.err.println(" -D " + TableInputFormat.SCAN_ROW_START + "="); + System.err.println(" -D " + TableInputFormat.SCAN_ROW_STOP + "="); System.err.println("For performance consider the following properties:\n" + " -Dhbase.client.scanner.caching=100\n" + " -Dmapred.map.tasks.speculative.execution=false\n" -- 2.1.0