Method Open

be/src/runtime/io/hdfs-file-reader.cc:60–66

}

Status HdfsFileReader::Open() {
  unique_lock<SpinLock> hdfs_lock(lock_);
  RETURN_IF_ERROR(scan_range_->cancel_status_);

  if (exclusive_hdfs_fh_ != nullptr) return Status::OK();
  return DoOpen();
}

Status HdfsFileReader::DoOpen() {
  auto io_mgr = scan_range_->io_mgr_;