public boolean isCommitted()

in hbase-client/src/main/java/org/apache/omid/transaction/SnapshotFilterImpl.java [515:544]

27 lines of code
7 McCabe index (conditional complexity)


    public boolean isCommitted(HBaseCellId hBaseCellId, long epoch, boolean isLowLatency) throws TransactionException {
        try {
            long timestamp = hBaseCellId.getTimestamp();
            CommitTimestamp tentativeCommitTimestamp =
                    locateCellCommitTimestamp(timestamp,
                            epoch,
                            new CommitTimestampLocatorImpl(hBaseCellId,
                                    Maps.<Long, Long>newHashMap(),
                                    tableAccessWrapper),
                            isLowLatency);

            // If transaction that added the cell was invalidated
            if (!tentativeCommitTimestamp.isValid()) {
                return false;
            }

            switch (tentativeCommitTimestamp.getLocation()) {
                case COMMIT_TABLE:
                case SHADOW_CELL:
                    return true;
                case NOT_PRESENT:
                    return false;
                case CACHE: // cache was empty
                default:
                    return false;
            }
        } catch (IOException e) {
            throw new TransactionException("Failure while checking if a transaction was committed", e);
        }
    }