| AddScanRanges(RequestContext *reader, const std::vector< ScanRange * > &ranges, bool schedule_immediately=false) | impala::DiskIoMgr | |
| AddWriteRange(RequestContext *writer, WriteRange *write_range) | impala::DiskIoMgr | |
| AssignQueue(const char *file, int disk_id, bool expected_local) | impala::DiskIoMgr | |
| BufferDescriptor class | impala::DiskIoMgr | friend |
| bytes_read_dn_cache(RequestContext *reader) const | impala::DiskIoMgr | |
| bytes_read_local(RequestContext *reader) const | impala::DiskIoMgr | |
| bytes_read_short_circuit(RequestContext *reader) const | impala::DiskIoMgr | |
| cached_read_options_ | impala::DiskIoMgr | private |
| CancelContext(RequestContext *context, bool wait_for_disks_completion=false) | impala::DiskIoMgr | |
| context_status(RequestContext *context) const | impala::DiskIoMgr | |
| DebugString() | impala::DiskIoMgr | |
| DEFAULT_QUEUE_CAPACITY | impala::DiskIoMgr | static |
| disk_queues_ | impala::DiskIoMgr | private |
| disk_thread_group_ | impala::DiskIoMgr | private |
| DiskIoMgr(int num_disks, int threads_per_disk, int min_buffer_size, int max_buffer_size) | impala::DiskIoMgr | |
| DiskIoMgr() | impala::DiskIoMgr | |
| DiskIoMgrTest_Buffers_Test class | impala::DiskIoMgr | friend |
| free_buffer_descs_ | impala::DiskIoMgr | private |
| free_buffers_ | impala::DiskIoMgr | private |
| free_buffers_idx(int64_t buffer_size) | impala::DiskIoMgr | private |
| free_buffers_lock_ | impala::DiskIoMgr | private |
| GcIoBuffers() | impala::DiskIoMgr | private |
| GetBufferDesc(RequestContext *reader, ScanRange *range, char *buffer, int64_t buffer_size) | impala::DiskIoMgr | private |
| GetFreeBuffer(int64_t *buffer_size) | impala::DiskIoMgr | private |
| GetNextRange(RequestContext *reader, ScanRange **range) | impala::DiskIoMgr | |
| GetNextRequestRange(DiskQueue *disk_queue, RequestRange **range, RequestContext **request_context) | impala::DiskIoMgr | private |
| GetReadThroughput() | impala::DiskIoMgr | |
| HandleReadFinished(DiskQueue *, RequestContext *, BufferDescriptor *) | impala::DiskIoMgr | private |
| HandleWriteFinished(RequestContext *writer, WriteRange *write_range, const Status &write_status) | impala::DiskIoMgr | private |
| Init(MemTracker *process_mem_tracker) | impala::DiskIoMgr | |
| max_buffer_size_ | impala::DiskIoMgr | private |
| max_read_buffer_size() const | impala::DiskIoMgr | inline |
| min_buffer_size_ | impala::DiskIoMgr | private |
| num_allocated_buffers() const | impala::DiskIoMgr | inline |
| num_allocated_buffers_ | impala::DiskIoMgr | private |
| num_buffers_in_readers() const | impala::DiskIoMgr | inline |
| num_buffers_in_readers_ | impala::DiskIoMgr | private |
| num_local_disks() const | impala::DiskIoMgr | inline |
| num_remote_disks() const | impala::DiskIoMgr | inline |
| num_remote_ranges(RequestContext *reader) const | impala::DiskIoMgr | |
| num_threads_per_disk_ | impala::DiskIoMgr | private |
| num_total_disks() const | impala::DiskIoMgr | inline |
| num_unstarted_ranges(RequestContext *reader) const | impala::DiskIoMgr | |
| pool_ | impala::DiskIoMgr | private |
| process_mem_tracker_ | impala::DiskIoMgr | private |
| queue_size(RequestContext *reader) const | impala::DiskIoMgr | |
| Read(RequestContext *reader, ScanRange *range, BufferDescriptor **buffer) | impala::DiskIoMgr | |
| read_timer_ | impala::DiskIoMgr | private |
| ReadRange(DiskQueue *disk_queue, RequestContext *reader, ScanRange *range) | impala::DiskIoMgr | private |
| RegisterContext(RequestContext **request_context, MemTracker *reader_mem_tracker=NULL) | impala::DiskIoMgr | |
| REMOTE_NUM_DISKS enum value | impala::DiskIoMgr | |
| REMOTE_S3_DISK_OFFSET enum value | impala::DiskIoMgr | |
| RemoteS3DiskId() const | impala::DiskIoMgr | inline |
| request_context_cache_ | impala::DiskIoMgr | private |
| ReturnBuffer(BufferDescriptor *buffer) | impala::DiskIoMgr | private |
| ReturnBufferDesc(BufferDescriptor *desc) | impala::DiskIoMgr | private |
| ReturnFreeBuffer(char *buffer, int64_t buffer_size) | impala::DiskIoMgr | private |
| ReturnFreeBuffer(BufferDescriptor *desc) | impala::DiskIoMgr | private |
| set_active_read_thread_counter(RequestContext *, RuntimeProfile::Counter *) | impala::DiskIoMgr | |
| set_bytes_read_counter(RequestContext *, RuntimeProfile::Counter *) | impala::DiskIoMgr | |
| set_disks_access_bitmap(RequestContext *, RuntimeProfile::Counter *) | impala::DiskIoMgr | |
| set_read_timer(RequestContext *, RuntimeProfile::Counter *) | impala::DiskIoMgr | |
| shut_down_ | impala::DiskIoMgr | private |
| total_bytes_read_counter_ | impala::DiskIoMgr | private |
| unexpected_remote_bytes(RequestContext *reader) const | impala::DiskIoMgr | |
| UnregisterContext(RequestContext *context) | impala::DiskIoMgr | |
| Validate() const | impala::DiskIoMgr | |
| ValidateScanRange(ScanRange *range) | impala::DiskIoMgr | private |
| WorkLoop(DiskQueue *queue) | impala::DiskIoMgr | private |
| Write(RequestContext *writer_context, WriteRange *write_range) | impala::DiskIoMgr | private |
| WriteRangeHelper(FILE *file_handle, WriteRange *write_range) | impala::DiskIoMgr | private |
| ~DiskIoMgr() | impala::DiskIoMgr | |