Adding support of timestamp-based scan filtering

1 files changed, 3 insertions, 0 deletions

diff --git a/src/main/java/parallelai/spyglass/hbase/HBaseScheme.java b/src/main/java/parallelai/spyglass/hbase/HBaseScheme.java
index 6f04f01..ba83a63 100644
--- a/src/main/java/parallelai/spyglass/hbase/HBaseScheme.java
+++ b/src/main/java/parallelai/spyglass/hbase/HBaseScheme.java
@@ -54,6 +54,7 @@ public class HBaseScheme
   
   /** Long timestamp */
   private long timeStamp;
+  private boolean useTimeStampInRead = false;
  
   /** String familyNames */
   private String[] familyNames;
@@ -112,6 +113,7 @@ public class HBaseScheme
     this.timeStamp = timeStamp;
     this.familyNames = familyNames;
     this.valueFields = valueFields;
+    this.useTimeStampInRead = (timeStamp > 0);
 
     setSourceSink(this.keyField, this.valueFields);
 
@@ -138,6 +140,7 @@ public class HBaseScheme
     this.keyField = keyField;
     this.valueFields = valueFields;
     this.timeStamp = System.currentTimeMillis();
+    this.useTimeStampInRead = false;
     
     validate();