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 | |