diff --git a/pom.xml b/pom.xml index 0a10bfa..ed12e65 100644 --- a/pom.xml +++ b/pom.xml @@ -15,9 +15,7 @@ limitations under the License. --> - + 4.0.0 org.sonatype.oss @@ -27,7 +25,7 @@ kr.co.vcnc.haeinsa haeinsa - 1.0.1-SNAPSHOT + 1.0.2-SNAPSHOT jar haeinsa @@ -313,7 +311,7 @@ - + @@ -326,7 +324,7 @@ - + diff --git a/src/main/java/kr/co/vcnc/haeinsa/HaeinsaGet.java b/src/main/java/kr/co/vcnc/haeinsa/HaeinsaGet.java index a4811b4..650cd44 100644 --- 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> familyMap = new TreeMap>(Bytes.BYTES_COMPARATOR); @@ -95,4 +96,12 @@ public byte[] getRow() { public Map> 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 index b41c1be..ca015a0 100644 --- 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> entry : get.getFamilyMap().entrySet()) { if (entry.getValue() == null) {