private void importIteration(
      UUID jobId,
      AuthData importAuthData,
      String jobIdPrefix,
      int copyIteration,
      DataModel exportedData)
      throws CopyException {

    monitor.debug(
        () -> jobIdPrefix + "Starting import, copy iteration: " + copyIteration,
        EventCode.COPIER_STARTED_IMPORT);

    CallableImporter callableImporter =
        new CallableImporter(
            importerProvider,
            jobId,
            idempotentImportExecutor,
            importAuthData,
            exportedData,
            metricRecorder);
    RetryingCallable<ImportResult> retryingImporter =
        new RetryingCallable<>(
            callableImporter,
            retryStrategyLibraryProvider.get(),
            Clock.systemUTC(),
            monitor,
            JobMetadata.getDataType(),
            JobMetadata.getImportService());
    boolean importSuccess = false;
    Stopwatch importStopwatch = Stopwatch.createStarted();
    try {
      ImportResult importResult = retryingImporter.call();
      importSuccess = importResult.getType() == ImportResult.ResultType.OK;
      if (importSuccess) {
        try {
          jobStore.addCounts(jobId, importResult.getCounts().orElse(null));
          jobStore.addBytes(jobId, importResult.getBytes().orElse(null));
        } catch (IOException | DatastoreException e) {
          monitor.debug(() -> jobIdPrefix + "Unable to add counts to job: ", e);
        }
      }
      monitor.debug(
          () -> jobIdPrefix + "Finished import, copy iteration: " + copyIteration,
          EventCode.COPIER_FINISHED_IMPORT);
    } catch (RetryException e) {
      if (!e.canSkip()) {
        throw convertToCopyException(jobIdPrefix, "import", e);
      }
    } catch (RuntimeException e) {
      throw convertToCopyException(jobIdPrefix, "import", e);
    } finally {
      metricRecorder.importPageFinished(
          JobMetadata.getDataType(),
          JobMetadata.getImportService(),
          importSuccess,
          importStopwatch.elapsed());
    }
  }
Kicks off transfer job {@code jobId} from {@code exporter} to {@code importer}.
portability-transfer/src/main/java/org/datatransferproject/transfer/copier/PortabilityAbstractInMemoryDataCopier.java