diff options
author | galarragas <galarragas@gmail.com> | 2014-03-17 14:08:53 +0000 |
---|---|---|
committer | galarragas <galarragas@gmail.com> | 2014-03-17 14:08:53 +0000 |
commit | ca77538beaea8f7529cbb1f6cd4570eb39d1e9fd (patch) | |
tree | 4ecefedf38a096c87098f44b13b4f9e4830eacb0 /src/main/java/parallelai/spyglass/hbase/HBaseTableSplitBase.java | |
parent | 74610d12d00064291a68423227761b2ddef2d4f0 (diff) | |
download | SpyGlass-ca77538beaea8f7529cbb1f6cd4570eb39d1e9fd.tar.gz SpyGlass-ca77538beaea8f7529cbb1f6cd4570eb39d1e9fd.zip |
Adding support of timestamp-based scan filtering
Diffstat (limited to 'src/main/java/parallelai/spyglass/hbase/HBaseTableSplitBase.java')
-rw-r--r-- | src/main/java/parallelai/spyglass/hbase/HBaseTableSplitBase.java | 14 |
1 files changed, 13 insertions, 1 deletions
diff --git a/src/main/java/parallelai/spyglass/hbase/HBaseTableSplitBase.java b/src/main/java/parallelai/spyglass/hbase/HBaseTableSplitBase.java index e24771f..3b72a1d 100644 --- a/src/main/java/parallelai/spyglass/hbase/HBaseTableSplitBase.java +++ b/src/main/java/parallelai/spyglass/hbase/HBaseTableSplitBase.java @@ -2,7 +2,6 @@ package parallelai.spyglass.hbase; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; -import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.util.Bytes; import org.apache.hadoop.mapred.InputSplit; @@ -35,6 +34,7 @@ public abstract class HBaseTableSplitBase implements InputSplit, protected boolean m_endRowInclusive = true; protected int m_versions = 1; protected boolean m_useSalt = false; + protected long m_timestamp = -1L; /** @return table name */ @@ -95,6 +95,13 @@ public abstract class HBaseTableSplitBase implements InputSplit, return this.m_regionName; } + public long getTimestamp() { + return m_timestamp; + } + + public void setTimestamp(long m_timestamp) { + this.m_timestamp = m_timestamp; + } public void copy(HBaseTableSplitBase that) { this.m_endRow = that.m_endRow; @@ -107,6 +114,7 @@ public abstract class HBaseTableSplitBase implements InputSplit, this.m_versions = that.m_versions; this.m_regionLocation = that.m_regionLocation; this.m_regionName = that.m_regionName; + this.m_timestamp = that.m_timestamp; } @Override @@ -139,6 +147,8 @@ public abstract class HBaseTableSplitBase implements InputSplit, break; } + this.m_timestamp = Bytes.toLong(Bytes.readByteArray(in)); + LOG.debug("READ and CREATED : " + this); } @@ -169,6 +179,8 @@ public abstract class HBaseTableSplitBase implements InputSplit, break; } + Bytes.writeByteArray(out, Bytes.toBytes(m_timestamp)); + LOG.debug("WROTE : " + out.toString()); } } |