public void cleanup()

in hbase-client/src/main/java/org/apache/omid/transaction/HBaseTransaction.java [81:101]

• 16 lines of code
• 5 McCabe index (conditional complexity)

    public void cleanup() {

        Map<Table,List<Mutation>> mutations = new HashMap<>();

        try {
            for (final HBaseCellId cell : getWriteSet()) {
                deleteCell(cell, mutations);
            }

            for (final HBaseCellId cell : getConflictFreeWriteSet()) {
                deleteCell(cell, mutations);
            }

            for (Map.Entry<Table,List<Mutation>> entry: mutations.entrySet()) {
                flushMutations(entry.getKey(), entry.getValue());
            }

        } catch (InterruptedException | IOException e) {
            LOG.warn("Failed cleanup for Tx {}. This issue has been ignored", getTransactionId(), e);
        }
    }