ignite transaction code

try(Transaction transaction = ignite.transactions().txStart(TransactionConcurrency.OPTIMISTIC, TransactionIsolation.READ_COMMITTED)) {
                    for(Column c : colsToBeUpdated) {
                         updateColumn(c)
                    }
                    transaction.commit();
                }



    private void updateColumn(Column c) {
        logger.info("Starting to update : {}", c.getName());
        List<Cache.Entry<String, ProductDetails>> entriesToBeUpdated = ProductCacheDAO.queryWithJoinClause(productCache,
                columnEntry.getKey().getIncomingDependency(), columnEntry.getValue().getUpdateInfo().getOutgoingDependencyValues());
        List<Object> outgoingDependencyValues = bulkUpdate(columnEntry, entriesToBeUpdated);
        updateTracker.addUpdate(new UpdateTracker.ColumnUpdateInfo(columnEntry.getKey(), outgoingDependencyValues));
        logger.info("Updated column {}. Total Entries Being Updated : {}", columnEntry.getKey().getColumnName(), entriesToBeUpdated.size());
    }