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, 10 insertions, 1 deletions

diff --git a/src/main/java/parallelai/spyglass/hbase/HBaseTableSplitRegional.java b/src/main/java/parallelai/spyglass/hbase/HBaseTableSplitRegional.java
index 1ebfa3d..ad5f78b 100644
--- a/src/main/java/parallelai/spyglass/hbase/HBaseTableSplitRegional.java
+++ b/src/main/java/parallelai/spyglass/hbase/HBaseTableSplitRegional.java
@@ -26,8 +26,9 @@ public class HBaseTableSplitRegional extends HBaseTableSplitBase {
 
 	}
 
-	public HBaseTableSplitRegional(String regionLocation) {
+	public HBaseTableSplitRegional(String regionLocation, String regionName) {
 		this.m_regionLocation = regionLocation;
+        this.m_regionName = regionName;
 	}
 
 	@Override
@@ -70,6 +71,8 @@ public class HBaseTableSplitRegional extends HBaseTableSplitBase {
 
         str.append(super.toString());
 
+        str.append(" REGIONAL => Region Location (" + m_regionLocation + ") Name (" + m_regionName + ")" );
+
         str.append(" GRANULAR = > ");
 
 		for (HBaseTableSplitGranular hbt : splits) {
@@ -114,14 +117,20 @@ public class HBaseTableSplitRegional extends HBaseTableSplitBase {
     }
 
     private Iterator<HBaseTableSplitGranular> splitIterator = null;
+    private int currSplitCount = 0;
 
     public HBaseTableSplitGranular getNextSplit() {
         splitIterator = (splitIterator == null) ? splits.listIterator() : splitIterator;
 
         if( splitIterator.hasNext() ) {
+            currSplitCount ++;
             return splitIterator.next();
         } else {
             return null;
         }
     }
+
+    public int getCurrSplitCount() {
+        return currSplitCount;
+    }
 }
\ No newline at end of file