Design a public tx API

/**
 * Ignite Transactions facade.
 */
public interface IgniteTransactions {
    /**
     * Begins the transaction.
     *
     * @return The future.
     */
    CompletableFuture<Transaction> beginAsync();

    /**
     * Synchronously executes a closure within a transaction.
     * <p>
     * If the closure is executed normally (no exceptions), the transaction is automatically committed.
     *
     * @param clo The closure.
     */
    void runInTransaction(Consumer<Transaction> clo);
}

/**
 * The transaction.
 */
public interface Transaction {
    /**
     * Synchronously commits a transaction.
     * Does nothing if it's already finished by committing or rolling back.
     */
    void commit();

    /**
     * Asynchronously commits a transaction.
     * Does nothing if it's already finished by committing or rolling back.
     *
     * @return The future.
     */
    CompletableFuture<Void> commitAsync();

    /**
     * Synchronously rolls back a transaction.
     * Does nothing if it's already finished by committing or rolling back.
     */
    void rollback();

    /**
     * Asynchronously rolls back a transaction.
     * Does nothing if it's already finished by committing or rolling back.
     *
     * @return The future.
     */
    CompletableFuture<Void> rollbackAsync();
}

        igniteTransactions.runInTransaction(tx -> {
            Table txTable = table.withTransaction(tx); // table view enlisted in the transaction.

            txTable.upsertAsync(...);

            tx.commit(); 
        });

        igniteTransactions.beginAsync()
            .thenApply(tx -> accounts.withTransaction(tx))
            .thenCompose(txTbl -> txTbl.upsertAsync(...).thenApply(i -> txTbl.transaction()))
            .thenCompose(Transaction::commitAsync);