@Override
  public PortabilityJob findJob(UUID jobId) {
    Preconditions.checkNotNull(jobId, "Job id is null");
    try {

      CloudTable table = tableClient.getTableReference(JOB_TABLE);

      TableOperation retrieve =
          TableOperation.retrieve(
              configuration.getPartitionKey(), jobId.toString(), DataWrapper.class);
      TableResult result = table.execute(retrieve);
      DataWrapper wrapper = result.getResultAsType();
      return configuration.getMapper().readValue(wrapper.getSerialized(), PortabilityJob.class);
    } catch (StorageException | URISyntaxException | IOException e) {
      throw new MicrosoftStorageException("Error finding 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