impala::DataStreamRecvr Member List

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

AddBatch(const TRowBatch &thrift_batch, int sender_id)	impala::DataStreamRecvr	private
buffer_full_total_timer_	impala::DataStreamRecvr	private
buffer_full_wall_timer_	impala::DataStreamRecvr	private
buffer_wall_timer_lock_	impala::DataStreamRecvr	private
bytes_received_counter_	impala::DataStreamRecvr	private
bytes_received_time_series_counter_	impala::DataStreamRecvr	private
CancelStream()	impala::DataStreamRecvr	private
Close()	impala::DataStreamRecvr
CreateMerger(const TupleRowComparator &less_than)	impala::DataStreamRecvr
data_arrival_timer_	impala::DataStreamRecvr	private
DataStreamMgr class	impala::DataStreamRecvr	friend
DataStreamRecvr(DataStreamMgr *stream_mgr, MemTracker *parent_tracker, const RowDescriptor &row_desc, const TUniqueId &fragment_instance_id, PlanNodeId dest_node_id, int num_senders, bool is_merging, int total_buffer_limit, RuntimeProfile *profile)	impala::DataStreamRecvr	private
deserialize_row_batch_timer_	impala::DataStreamRecvr	private
dest_node_id() const	impala::DataStreamRecvr	inline
dest_node_id_	impala::DataStreamRecvr	private
ExceedsLimit(int batch_size)	impala::DataStreamRecvr	inlineprivate
first_batch_wait_total_timer_	impala::DataStreamRecvr	private
fragment_instance_id() const	impala::DataStreamRecvr	inline
fragment_instance_id_	impala::DataStreamRecvr	private
GetBatch(RowBatch **next_batch)	impala::DataStreamRecvr
GetNext(RowBatch *output_batch, bool *eos)	impala::DataStreamRecvr
is_merging_	impala::DataStreamRecvr	private
mem_tracker() const	impala::DataStreamRecvr	inline
mem_tracker_	impala::DataStreamRecvr	private
merger_	impala::DataStreamRecvr	private
mgr_	impala::DataStreamRecvr	private
num_buffered_bytes_	impala::DataStreamRecvr	private
profile_	impala::DataStreamRecvr	private
RemoveSender(int sender_id)	impala::DataStreamRecvr	private
row_desc() const	impala::DataStreamRecvr	inline
row_desc_	impala::DataStreamRecvr	private
sender_queue_pool_	impala::DataStreamRecvr	private
sender_queues_	impala::DataStreamRecvr	private
total_buffer_limit_	impala::DataStreamRecvr	private
TransferAllResources(RowBatch *transfer_batch)	impala::DataStreamRecvr
~DataStreamRecvr()	impala::DataStreamRecvr