private <T> T find(Class<T> type, String rowKey, String tableName) {
    try {

      CloudTable table = tableClient.getTableReference(tableName);
      TableOperation retrieve =
          TableOperation.retrieve(configuration.getPartitionKey(), rowKey, DataWrapper.class);
      TableResult result = table.execute(retrieve);
      DataWrapper wrapper = result.getResultAsType();
      return configuration.getMapper().readValue(wrapper.getSerialized(), type);
    } catch (StorageException | IOException | URISyntaxException e) {
      throw new MicrosoftStorageException("Error finding data for rowKey: " + rowKey, 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