1. Created a mapper per region as ooposed to mapper per region server4.1.1

2. Added progress indicators
3. Better logging

1 files changed, 3 insertions, 0 deletions

diff --git a/src/main/java/parallelai/spyglass/hbase/HBaseRecordReaderBase.java b/src/main/java/parallelai/spyglass/hbase/HBaseRecordReaderBase.java
index 37858ad..e0d0cbe 100644
--- a/src/main/java/parallelai/spyglass/hbase/HBaseRecordReaderBase.java
+++ b/src/main/java/parallelai/spyglass/hbase/HBaseRecordReaderBase.java
@@ -24,6 +24,7 @@ public abstract class HBaseRecordReaderBase implements
         RecordReader<ImmutableBytesWritable, Result> {
 
     protected TreeSet<String> keyList;
+    protected long initialNoOfKeys = 0;
     protected HBaseConstants.SourceMode sourceMode;
     protected boolean endRowInclusive = true;
     protected int versions = 1;
@@ -39,6 +40,7 @@ public abstract class HBaseRecordReaderBase implements
 
     protected boolean logScannerActivity = false;
     protected int logPerRowCount = 100;
+    protected int noOfLogCount = 0;
 
     @Override
     public String toString() {
@@ -107,6 +109,7 @@ public abstract class HBaseRecordReaderBase implements
 
     public void setKeyList(TreeSet<String> keyList) {
         this.keyList = keyList;
+        initialNoOfKeys = (this.keyList == null) ? 0 : this.keyList.size();
     }
 
     public void setVersions(int versions) {