Adding support of timestamp-based scan filtering

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 e0d0cbe..cc64cb4 100644
--- a/src/main/java/parallelai/spyglass/hbase/HBaseRecordReaderBase.java
+++ b/src/main/java/parallelai/spyglass/hbase/HBaseRecordReaderBase.java
@@ -41,6 +41,7 @@ public abstract class HBaseRecordReaderBase implements
     protected boolean logScannerActivity = false;
     protected int logPerRowCount = 100;
     protected int noOfLogCount = 0;
+    protected long timestamp = -1;
 
     @Override
     public String toString() {
@@ -116,6 +117,8 @@ public abstract class HBaseRecordReaderBase implements
         this.versions = versions;
     }
 
+    public void setTimestamp(long timestamp) {this.timestamp = timestamp; }
+
     public void setUseSalt(boolean useSalt) {
         this.useSalt = useSalt;
     }