| 987 | } |
| 988 | |
| 989 | Status DiskIoMgr::GetCachedHdfsFileHandle(const hdfsFS& fs, std::string* fname, |
| 990 | int64_t mtime, RequestContext* reader, FileHandleCache::Accessor* accessor) { |
| 991 | bool cache_hit; |
| 992 | SCOPED_TIMER(reader->open_file_timer_); |
| 993 | RETURN_IF_ERROR( |
| 994 | file_handle_cache_.GetFileHandle(fs, fname, mtime, false, accessor, &cache_hit)); |
| 995 | if (cache_hit) { |
| 996 | ImpaladMetrics::IO_MGR_CACHED_FILE_HANDLES_HIT_RATIO->Update(1L); |
| 997 | ImpaladMetrics::IO_MGR_CACHED_FILE_HANDLES_HIT_COUNT->Increment(1L); |
| 998 | reader->cached_file_handles_hit_count_.Add(1L); |
| 999 | } else { |
| 1000 | ImpaladMetrics::IO_MGR_CACHED_FILE_HANDLES_HIT_RATIO->Update(0L); |
| 1001 | ImpaladMetrics::IO_MGR_CACHED_FILE_HANDLES_MISS_COUNT->Increment(1L); |
| 1002 | reader->cached_file_handles_miss_count_.Add(1L); |
| 1003 | } |
| 1004 | return Status::OK(); |
| 1005 | } |
| 1006 | |
| 1007 | Status DiskIoMgr::ReopenCachedHdfsFileHandle(const hdfsFS& fs, std::string* fname, |
| 1008 | int64_t mtime, RequestContext* reader, FileHandleCache::Accessor* accessor) { |
no test coverage detected