1 files changed, 53 insertions, 0 deletions
diff --git a/src/main/java/parallelai/spyglass/hbase/HBaseConfigUtils.java b/src/main/java/parallelai/spyglass/hbase/HBaseConfigUtils.java
new file mode 100644
index 0000000..598a988
--- /dev/null
+++ b/src/main/java/parallelai/spyglass/hbase/HBaseConfigUtils.java
@@ -0,0 +1,53 @@
+package parallelai.spyglass.hbase;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
+import java.io.IOException;
+
+/**
+ * Created with IntelliJ IDEA.
+ * User: chand_000
+ * Date: 29/08/13
+ * Time: 17:25
+ * To change this template use File | Settings | File Templates.
+ */
+public class HBaseConfigUtils {
+    static final Log LOG = LogFactory.getLog(HBaseConfigUtils.class);
+
+    public static void setRecordReaderParms(HBaseRecordReaderBase trr, HBaseTableSplitBase tSplit) throws IOException {
+        switch (tSplit.getSourceMode()) {
+            case SCAN_ALL:
+            case SCAN_RANGE: {
+                LOG.debug(String.format(
+                        "For split [%s] we have start key (%s) and stop key (%s)",
+                        tSplit, tSplit.getStartRow(), tSplit.getEndRow()));
+
+                trr.setStartRow(tSplit.getStartRow());
+                trr.setEndRow(tSplit.getEndRow());
+                trr.setEndRowInclusive(tSplit.getEndRowInclusive());
+                trr.setUseSalt(tSplit.getUseSalt());
+            }
+
+            break;
+
+            case GET_LIST: {
+                LOG.debug(String.format("For split [%s] we have key list (%s)",
+                        tSplit, tSplit.getKeyList()));
+
+                trr.setKeyList(tSplit.getKeyList());
+                trr.setVersions(tSplit.getVersions());
+                trr.setUseSalt(tSplit.getUseSalt());
+            }
+
+            break;
+
+            default:
+                throw new IOException("Unknown source mode : "
+                        + tSplit.getSourceMode());
+        }
+
+        trr.setSourceMode(tSplit.getSourceMode());
+    }
+
+}