AddRow(TupleRow *row, uint8_t **dst=NULL) | impala::BufferedTupleStream | inline |
AllocateRow(int size) | impala::BufferedTupleStream | inline |
block_mgr_ | impala::BufferedTupleStream | private |
block_mgr_client_ | impala::BufferedTupleStream | private |
block_start_idx_ | impala::BufferedTupleStream | private |
blocks_ | impala::BufferedTupleStream | private |
blocks_pinned() const | impala::BufferedTupleStream | inline |
blocks_unpinned() const | impala::BufferedTupleStream | inline |
BufferedTupleStream(RuntimeState *state, const RowDescriptor &row_desc, BufferedBlockMgr *block_mgr, BufferedBlockMgr::Client *client, bool use_initial_small_buffers=true, bool delete_on_read=false, bool read_write=false) | impala::BufferedTupleStream | |
byte_size() const | impala::BufferedTupleStream | inline |
bytes_in_mem(bool ignore_current) const | impala::BufferedTupleStream | |
Close() | impala::BufferedTupleStream | |
closed_ | impala::BufferedTupleStream | private |
ComputeNumNullIndicatorBytes(int block_size) const | impala::BufferedTupleStream | private |
ComputeRowSize(TupleRow *row) const | impala::BufferedTupleStream | private |
DebugString() const | impala::BufferedTupleStream | |
DeepCopy(TupleRow *row, uint8_t **dst) | impala::BufferedTupleStream | private |
DeepCopyInternal(TupleRow *row, uint8_t **dst) | impala::BufferedTupleStream | private |
delete_on_read_ | impala::BufferedTupleStream | private |
desc_ | impala::BufferedTupleStream | private |
fixed_tuple_row_size_ | impala::BufferedTupleStream | private |
get_new_block_timer_ | impala::BufferedTupleStream | private |
GetNext(RowBatch *batch, bool *eos, std::vector< RowIdx > *indices=NULL) | impala::BufferedTupleStream | |
GetNextInternal(RowBatch *batch, bool *eos, std::vector< RowIdx > *indices) | impala::BufferedTupleStream | private |
GetNextInternal(RowBatch *batch, bool *eos, vector< RowIdx > *indices) | impala::BufferedTupleStream | |
GetRows(boost::scoped_ptr< RowBatch > *batch, bool *got_rows) | impala::BufferedTupleStream | |
GetTupleRow(const RowIdx &idx, TupleRow *row) const | impala::BufferedTupleStream | inline |
has_read_block() const | impala::BufferedTupleStream | inline |
has_write_block() const | impala::BufferedTupleStream | inline |
Init(RuntimeProfile *profile=NULL, bool pinned=true) | impala::BufferedTupleStream | |
is_pinned() const | impala::BufferedTupleStream | inline |
NewBlockForWrite(int min_size, bool *got_block) | impala::BufferedTupleStream | private |
NextBlockForRead() | impala::BufferedTupleStream | private |
null_indicators_read_block_ | impala::BufferedTupleStream | private |
null_indicators_write_block_ | impala::BufferedTupleStream | private |
nullable_tuple_ | impala::BufferedTupleStream | private |
num_pinned_ | impala::BufferedTupleStream | private |
num_rows() const | impala::BufferedTupleStream | inline |
num_rows_ | impala::BufferedTupleStream | private |
num_small_blocks_ | impala::BufferedTupleStream | private |
pin_timer_ | impala::BufferedTupleStream | private |
pinned_ | impala::BufferedTupleStream | private |
PinStream(bool already_reserved, bool *pinned) | impala::BufferedTupleStream | |
PrepareForRead(bool *got_buffer=NULL) | impala::BufferedTupleStream | |
read_block_ | impala::BufferedTupleStream | private |
read_block_idx_ | impala::BufferedTupleStream | private |
read_bytes_ | impala::BufferedTupleStream | private |
read_ptr_ | impala::BufferedTupleStream | private |
read_tuple_idx_ | impala::BufferedTupleStream | private |
read_write_ | impala::BufferedTupleStream | private |
rows_returned() const | impala::BufferedTupleStream | inline |
rows_returned_ | impala::BufferedTupleStream | private |
state_ | impala::BufferedTupleStream | private |
status() const | impala::BufferedTupleStream | inline |
status_ | impala::BufferedTupleStream | private |
string_slots_ | impala::BufferedTupleStream | private |
SwitchToIoBuffers(bool *got_buffer) | impala::BufferedTupleStream | |
total_byte_size_ | impala::BufferedTupleStream | private |
unpin_timer_ | impala::BufferedTupleStream | private |
UnpinBlock(BufferedBlockMgr::Block *block) | impala::BufferedTupleStream | private |
UnpinStream(bool all=false) | impala::BufferedTupleStream | |
use_small_buffers_ | impala::BufferedTupleStream | private |
using_small_buffers() const | impala::BufferedTupleStream | inline |
write_block_ | impala::BufferedTupleStream | private |
write_tuple_idx_ | impala::BufferedTupleStream | private |