add cache blocks option in HaeinsaGet

VCNC · Mar 10, 2014 · 2179b5c · 2179b5c
1 parent 6d3be9c
commit 2179b5c
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/src/main/java/kr/co/vcnc/haeinsa/HaeinsaGet.java b/src/main/java/kr/co/vcnc/haeinsa/HaeinsaGet.java
@@ -30,6 +30,7 @@
  */
 public class HaeinsaGet {
     private byte[] row;
+    private boolean cacheBlocks;
     private Map<byte[], NavigableSet<byte[]>> familyMap =
             new TreeMap<byte[], NavigableSet<byte[]>>(Bytes.BYTES_COMPARATOR);
 
@@ -95,4 +96,12 @@ public byte[] getRow() {
     public Map<byte[], NavigableSet<byte[]>> getFamilyMap() {
         return this.familyMap;
     }
+
+    public void setCacheBlocks(boolean cacheBlocks) {
+        this.cacheBlocks = cacheBlocks;
+    }
+
+    public boolean getCacheBlocks() {
+        return cacheBlocks;
+    }
 }
diff --git a/src/main/java/kr/co/vcnc/haeinsa/HaeinsaTable.java b/src/main/java/kr/co/vcnc/haeinsa/HaeinsaTable.java
@@ -132,6 +132,7 @@ public HaeinsaResult get(@Nullable HaeinsaTransaction tx, HaeinsaGet get) throws
         HaeinsaRowTransaction rowState = tableState.getRowStates().get(row);
         boolean lockInclusive = false;
         Get hGet = new Get(get.getRow());
+        hGet.setCacheBlocks(get.getCacheBlocks());
 
         for (Entry<byte[], NavigableSet<byte[]>> entry : get.getFamilyMap().entrySet()) {
             if (entry.getValue() == null) {