You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@omid.apache.org by yonigottesman <gi...@git.apache.org> on 2018/07/29 06:15:19 UTC
[GitHub] incubator-omid pull request #39: [OMID-105] When a tentative family deletion...
Github user yonigottesman commented on a diff in the pull request:
https://github.com/apache/incubator-omid/pull/39#discussion_r205961769
--- Diff: hbase-client/src/main/java/org/apache/omid/transaction/SnapshotFilterImpl.java ---
@@ -298,26 +291,62 @@ public CommitTimestamp locateCellCommitTimestamp(long cellStartTimestamp, long e
return commitCache;
}
- private void buildFamilyDeletionCache(List<Cell> rawCells, Map<String, List<Cell>> familyDeletionCache) {
-
+ private void buildFamilyDeletionCache(HBaseTransaction transaction, List<Cell> rawCells, Map<String, Long> familyDeletionCache, Map<Long, Long> commitCache, Map<String,byte[]> attributeMap) throws IOException {
for (Cell cell : rawCells) {
if (CellUtil.matchingQualifier(cell, CellUtils.FAMILY_DELETE_QUALIFIER) &&
--- End diff --
If we can use java 8, filter rawCells with java stream.
export
" if (CellUtil.matchingQualifier(cell, CellUtils.FAMILY_DELETE_QUALIFIER) &&...."
to a function
isFamilyDeleteCell(Cell) in CellUtils and call it from stream filter
---