all_io_buffers_ | impala::BufferedBlockMgr | private |
available_allocated_buffers() const | impala::BufferedBlockMgr | inline |
available_buffers(Client *client) const | impala::BufferedBlockMgr | |
block_size_counter_ | impala::BufferedBlockMgr | private |
block_write_threshold_ | impala::BufferedBlockMgr | private |
BlockMgrsMap typedef | impala::BufferedBlockMgr | private |
buffer_available_cv_ | impala::BufferedBlockMgr | private |
buffer_wait_timer_ | impala::BufferedBlockMgr | private |
buffered_pin_counter_ | impala::BufferedBlockMgr | private |
BufferedBlockMgr(RuntimeState *state, int64_t block_size) | impala::BufferedBlockMgr | private |
bytes_allocated() const | impala::BufferedBlockMgr | |
bytes_written_counter_ | impala::BufferedBlockMgr | private |
Cancel() | impala::BufferedBlockMgr | |
check_integrity_ | impala::BufferedBlockMgr | private |
ClearReservations(Client *client) | impala::BufferedBlockMgr | |
ClearTmpReservation(Client *client) | impala::BufferedBlockMgr | |
Client | impala::BufferedBlockMgr | friend |
ConsumeMemory(Client *client, int64_t size) | impala::BufferedBlockMgr | |
Create(RuntimeState *state, MemTracker *parent, RuntimeProfile *profile, int64_t mem_limit, int64_t buffer_size, boost::shared_ptr< BufferedBlockMgr > *block_mgr) | impala::BufferedBlockMgr | static |
created_block_counter_ | impala::BufferedBlockMgr | private |
DebugInternal() const | impala::BufferedBlockMgr | private |
DebugString(Client *client=NULL) | impala::BufferedBlockMgr | |
Decrypt(Block *block) | impala::BufferedBlockMgr | private |
DeleteBlock(Block *block) | impala::BufferedBlockMgr | private |
DeleteOrUnpinBlock(Block *block, bool unpin) | impala::BufferedBlockMgr | private |
disable_spill_ | impala::BufferedBlockMgr | private |
disk_read_timer_ | impala::BufferedBlockMgr | private |
Encrypt(Block *block, uint8_t **outbuf) | impala::BufferedBlockMgr | private |
EncryptDone(Block *block) | impala::BufferedBlockMgr | private |
encryption_ | impala::BufferedBlockMgr | private |
encryption_timer_ | impala::BufferedBlockMgr | private |
FindBuffer(boost::unique_lock< boost::mutex > &lock, BufferDescriptor **buffer) | impala::BufferedBlockMgr | private |
FindBufferForBlock(Block *block, bool *in_mem) | impala::BufferedBlockMgr | private |
free_io_buffers_ | impala::BufferedBlockMgr | private |
get_tracker(Client *client) const | impala::BufferedBlockMgr | |
GetNewBlock(Client *client, Block *unpin_block, Block **block, int64_t len=-1) | impala::BufferedBlockMgr | |
GetNumReservedBlocks() | impala::BufferedBlockMgr | inlinestatic |
GetUnusedBlock(Client *client) | impala::BufferedBlockMgr | private |
Init(DiskIoMgr *io_mgr, RuntimeProfile *profile, MemTracker *parent_tracker, int64_t mem_limit) | impala::BufferedBlockMgr | private |
initialized_ | impala::BufferedBlockMgr | private |
InitTmpFiles() | impala::BufferedBlockMgr | private |
integrity_check_timer_ | impala::BufferedBlockMgr | private |
io_mgr_ | impala::BufferedBlockMgr | private |
io_request_context_ | impala::BufferedBlockMgr | private |
is_cancelled_ | impala::BufferedBlockMgr | private |
lock_ | impala::BufferedBlockMgr | private |
max_block_size() const | impala::BufferedBlockMgr | inline |
max_block_size_ | impala::BufferedBlockMgr | private |
mem_limit_counter_ | impala::BufferedBlockMgr | private |
mem_tracker_ | impala::BufferedBlockMgr | private |
MemLimitTooLowError(Client *client) | impala::BufferedBlockMgr | |
next_block_index_ | impala::BufferedBlockMgr | private |
non_local_outstanding_writes_ | impala::BufferedBlockMgr | private |
num_free_buffers() const | impala::BufferedBlockMgr | inline |
num_pinned_buffers(Client *client) const | impala::BufferedBlockMgr | |
num_reserved_buffers_remaining(Client *client) const | impala::BufferedBlockMgr | |
obj_pool_ | impala::BufferedBlockMgr | private |
outstanding_writes_counter_ | impala::BufferedBlockMgr | private |
PinBlock(Block *block, bool *pinned, Block *src, bool unpin) | impala::BufferedBlockMgr | private |
profile() | impala::BufferedBlockMgr | inline |
profile_ | impala::BufferedBlockMgr | private |
query_id_ | impala::BufferedBlockMgr | private |
query_to_block_mgrs_ | impala::BufferedBlockMgr | privatestatic |
recycled_blocks_counter_ | impala::BufferedBlockMgr | private |
RegisterClient(int num_reserved_buffers, MemTracker *tracker, RuntimeState *state, Client **client) | impala::BufferedBlockMgr | |
ReleaseMemory(Client *client, int64_t size) | impala::BufferedBlockMgr | |
remaining_unreserved_buffers() const | impala::BufferedBlockMgr | private |
ReturnUnusedBlock(Block *block) | impala::BufferedBlockMgr | private |
SetHash(Block *block) | impala::BufferedBlockMgr | private |
static_block_mgrs_lock_ | impala::BufferedBlockMgr | privatestatic |
tmp_files_ | impala::BufferedBlockMgr | private |
total_pinned_buffers_ | impala::BufferedBlockMgr | private |
TransferBuffer(Block *dst, Block *src, bool unpin) | impala::BufferedBlockMgr | private |
TryAcquireTmpReservation(Client *client, int num_buffers) | impala::BufferedBlockMgr | |
unfullfilled_reserved_buffers_ | impala::BufferedBlockMgr | private |
UnpinBlock(Block *block) | impala::BufferedBlockMgr | private |
unpinned_blocks_ | impala::BufferedBlockMgr | private |
unused_blocks_ | impala::BufferedBlockMgr | private |
Validate() const | impala::BufferedBlockMgr | private |
VerifyHash(Block *block) | impala::BufferedBlockMgr | private |
WriteComplete(Block *block, const Status &write_status) | impala::BufferedBlockMgr | private |
writes_issued() const | impala::BufferedBlockMgr | inline |
writes_issued_ | impala::BufferedBlockMgr | private |
WriteUnpinnedBlock(Block *block) | impala::BufferedBlockMgr | private |
WriteUnpinnedBlocks() | impala::BufferedBlockMgr | private |
~BufferedBlockMgr() | impala::BufferedBlockMgr | |