private void remove(UUID jobId, String tableName) throws IOException {
    try {

      CloudTable table = tableClient.getTableReference(tableName);
      TableOperation retrieve =
          TableOperation.retrieve(
              configuration.getPartitionKey(), jobId.toString(), DataWrapper.class);
      TableResult result = table.execute(retrieve);
      DataWrapper wrapper = result.getResultAsType();

      TableOperation delete = TableOperation.delete(wrapper);
      table.execute(delete);

    } catch (StorageException | URISyntaxException e) {
      throw new IOException("Error removing data for job: " + jobId, e);
    }
  }
Uses the Azure Cosmos DB Table Storage API to persist job data.
extensions/cloud/portability-cloud-microsoft/src/main/java/org/datatransferproject/cloud/microsoft/cosmos/AzureTableStore.java