aboutsummaryrefslogtreecommitdiffstats
path: root/src/main/java/parallelai/spyglass/hbase/HBaseScheme.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/parallelai/spyglass/hbase/HBaseScheme.java')
-rw-r--r--src/main/java/parallelai/spyglass/hbase/HBaseScheme.java3
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();