From ca77538beaea8f7529cbb1f6cd4570eb39d1e9fd Mon Sep 17 00:00:00 2001
From: galarragas <galarragas@gmail.com>
Date: Mon, 17 Mar 2014 14:08:53 +0000
Subject: Adding support of timestamp-based scan filtering

---
 src/main/java/parallelai/spyglass/hbase/HBaseScheme.java | 3 +++
 1 file changed, 3 insertions(+)

(limited to 'src/main/java/parallelai/spyglass/hbase/HBaseScheme.java')

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();
 
-- 
cgit v1.2.3