code: @Override
      public CompletableFuture<Void> completeCommittingTransactions(VersionedMetadata<CommittingTransactionsRecord> record) {
          // create all transaction entries in committing txn list. 
          // remove all entries from active txn in epoch. 
          // reset CommittingTxnRecord
          long time = System.currentTimeMillis();
  
          Map<String, byte[]> completedRecords = record.getObject().getTransactionsToCommit().stream()
                                                                 .collect(Collectors.toMap(UUID::toString, 
                                                                         x -> new CompletedTxnRecord(time, TxnStatus.COMMITTED).toBytes()));
          CompletableFuture<Void> future;
          if (record.getObject().getTransactionsToCommit().size() == 0) {
              future = CompletableFuture.completedFuture(null);
          } else {
              future = createCompletedTxEntries(completedRecords)
                      .thenCompose(x -> getTransactionsInEpochTable(record.getObject().getEpoch())
                              .thenCompose(table -> storeHelper.removeEntries(table, completedRecords.keySet())))
                      .thenCompose(x -> tryRemoveOlderTransactionsInEpochTables(epoch -> epoch < record.getObject().getEpoch()));
          }
          return future
                  .thenCompose(x -> Futures.toVoid(updateCommittingTxnRecord(new VersionedMetadata<>(CommittingTransactionsRecord.EMPTY,
                          record.getVersion()))));
      }
docs: region overrides