Impala
Impalaistheopensource,nativeanalyticdatabaseforApacheHadoop.
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
impala::DiskIoMgr Member List

This is the complete list of members for impala::DiskIoMgr, including all inherited members.

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 classimpala::DiskIoMgrfriend
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::DiskIoMgrprivate
CancelContext(RequestContext *context, bool wait_for_disks_completion=false)impala::DiskIoMgr
context_status(RequestContext *context) const impala::DiskIoMgr
DebugString()impala::DiskIoMgr
DEFAULT_QUEUE_CAPACITYimpala::DiskIoMgrstatic
disk_queues_impala::DiskIoMgrprivate
disk_thread_group_impala::DiskIoMgrprivate
DiskIoMgr(int num_disks, int threads_per_disk, int min_buffer_size, int max_buffer_size)impala::DiskIoMgr
DiskIoMgr()impala::DiskIoMgr
DiskIoMgrTest_Buffers_Test classimpala::DiskIoMgrfriend
free_buffer_descs_impala::DiskIoMgrprivate
free_buffers_impala::DiskIoMgrprivate
free_buffers_idx(int64_t buffer_size)impala::DiskIoMgrprivate
free_buffers_lock_impala::DiskIoMgrprivate
GcIoBuffers()impala::DiskIoMgrprivate
GetBufferDesc(RequestContext *reader, ScanRange *range, char *buffer, int64_t buffer_size)impala::DiskIoMgrprivate
GetFreeBuffer(int64_t *buffer_size)impala::DiskIoMgrprivate
GetNextRange(RequestContext *reader, ScanRange **range)impala::DiskIoMgr
GetNextRequestRange(DiskQueue *disk_queue, RequestRange **range, RequestContext **request_context)impala::DiskIoMgrprivate
GetReadThroughput()impala::DiskIoMgr
HandleReadFinished(DiskQueue *, RequestContext *, BufferDescriptor *)impala::DiskIoMgrprivate
HandleWriteFinished(RequestContext *writer, WriteRange *write_range, const Status &write_status)impala::DiskIoMgrprivate
Init(MemTracker *process_mem_tracker)impala::DiskIoMgr
max_buffer_size_impala::DiskIoMgrprivate
max_read_buffer_size() const impala::DiskIoMgrinline
min_buffer_size_impala::DiskIoMgrprivate
num_allocated_buffers() const impala::DiskIoMgrinline
num_allocated_buffers_impala::DiskIoMgrprivate
num_buffers_in_readers() const impala::DiskIoMgrinline
num_buffers_in_readers_impala::DiskIoMgrprivate
num_local_disks() const impala::DiskIoMgrinline
num_remote_disks() const impala::DiskIoMgrinline
num_remote_ranges(RequestContext *reader) const impala::DiskIoMgr
num_threads_per_disk_impala::DiskIoMgrprivate
num_total_disks() const impala::DiskIoMgrinline
num_unstarted_ranges(RequestContext *reader) const impala::DiskIoMgr
pool_impala::DiskIoMgrprivate
process_mem_tracker_impala::DiskIoMgrprivate
queue_size(RequestContext *reader) const impala::DiskIoMgr
Read(RequestContext *reader, ScanRange *range, BufferDescriptor **buffer)impala::DiskIoMgr
read_timer_impala::DiskIoMgrprivate
ReadRange(DiskQueue *disk_queue, RequestContext *reader, ScanRange *range)impala::DiskIoMgrprivate
RegisterContext(RequestContext **request_context, MemTracker *reader_mem_tracker=NULL)impala::DiskIoMgr
REMOTE_NUM_DISKS enum valueimpala::DiskIoMgr
REMOTE_S3_DISK_OFFSET enum valueimpala::DiskIoMgr
RemoteS3DiskId() const impala::DiskIoMgrinline
request_context_cache_impala::DiskIoMgrprivate
ReturnBuffer(BufferDescriptor *buffer)impala::DiskIoMgrprivate
ReturnBufferDesc(BufferDescriptor *desc)impala::DiskIoMgrprivate
ReturnFreeBuffer(char *buffer, int64_t buffer_size)impala::DiskIoMgrprivate
ReturnFreeBuffer(BufferDescriptor *desc)impala::DiskIoMgrprivate
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::DiskIoMgrprivate
total_bytes_read_counter_impala::DiskIoMgrprivate
unexpected_remote_bytes(RequestContext *reader) const impala::DiskIoMgr
UnregisterContext(RequestContext *context)impala::DiskIoMgr
Validate() const impala::DiskIoMgr
ValidateScanRange(ScanRange *range)impala::DiskIoMgrprivate
WorkLoop(DiskQueue *queue)impala::DiskIoMgrprivate
Write(RequestContext *writer_context, WriteRange *write_range)impala::DiskIoMgrprivate
WriteRangeHelper(FILE *file_handle, WriteRange *write_range)impala::DiskIoMgrprivate
~DiskIoMgr()impala::DiskIoMgr