Method GetConnection

be/src/runtime/tmp-file-mgr.cc:851–857

}

Status TmpDirS3::GetConnection(TmpFileMgr* tmp_mgr, hdfsFS* hdfs_conn) {
  DCHECK(tmp_mgr != nullptr);
  DCHECK(!path_.empty());
  DCHECK(hdfs_conn != nullptr);
  return HdfsFsCache::instance()->GetConnection(
      path_, hdfs_conn, &(tmp_mgr->hdfs_conns_), tmp_mgr->s3a_options());
}

Status TmpDirS3::VerifyAndCreate(MetricGroup* metrics, vector<bool>* is_tmp_dir_on_disk,
    bool need_local_buffer_dir, TmpFileMgr* tmp_mgr) {