public AtlasImportResult importData(AtlasImportRequest request, AtlasReplInfo atlasReplInfo) throws Exception {
    AtlasImportResult defaultResult = getDefaultAtlasImportResult(request);
    Path exportFilePath = new Path(atlasReplInfo.getStagingDir(), ReplUtils.REPL_ATLAS_EXPORT_FILE_NAME);
    FileSystem fs = FileSystem.get(exportFilePath.toUri(), atlasReplInfo.getConf());
    if (!fs.exists(exportFilePath)) {
      LOG.info("There is nothing to load, returning the default result.");
      return defaultResult;
    }
    LOG.debug("Atlas import data request: {}" + request);
    return invokeWithRetry(new Callable<AtlasImportResult>() {
      @Override
      public AtlasImportResult call() throws Exception {
        InputStream is = null;
        try {
          SecurityUtils.reloginExpiringKeytabUser();
          is = fs.open(exportFilePath);
          return clientV2.importData(request, is);
        } finally {
          if (is != null) {
            is.close();
          }
        }
      }
    });
  }
Implementation of RESTClient, encapsulates Atlas' REST APIs.
ql/src/java/org/apache/hadoop/hive/ql/exec/repl/atlas/AtlasRestClientImpl.java