impala::DataStreamSender Member List

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

broadcast_	impala::DataStreamSender	private
bytes_sent_counter_	impala::DataStreamSender	private
channels_	impala::DataStreamSender	private
Close(RuntimeState *state)	impala::DataStreamSender	virtual
closed_	impala::DataStreamSender	private
CreateDataSink(ObjectPool *pool, const TDataSink &thrift_sink, const std::vector< TExpr > &output_exprs, const TPlanFragmentExecParams &params, const RowDescriptor &row_desc, boost::scoped_ptr< DataSink > *sink)	impala::DataSink	static
current_channel_idx_	impala::DataStreamSender	private
current_thrift_batch_	impala::DataStreamSender	private
DataSink()	impala::DataSink	inline
DataStreamSender(ObjectPool *pool, int sender_id, const RowDescriptor &row_desc, const TDataStreamSink &sink, const std::vector< TPlanFragmentDestination > &destinations, int per_channel_buffer_size)	impala::DataStreamSender
dest_node_id_	impala::DataStreamSender	private
expr_mem_tracker_	impala::DataSink	protected
GetNumDataBytesSent() const	impala::DataStreamSender
mem_tracker_	impala::DataStreamSender	private
MergeInsertStats(const TInsertStats &src_stats, TInsertStats *dst_stats)	impala::DataSink	static
network_throughput_	impala::DataStreamSender	private
Open(RuntimeState *state)	impala::DataStreamSender	virtual
OutputInsertStats(const PartitionStatusMap &stats, const std::string &prefix="")	impala::DataSink	static
overall_throughput_	impala::DataStreamSender	private
partition_expr_ctxs_	impala::DataStreamSender	private
pool_	impala::DataStreamSender	private
Prepare(RuntimeState *state)	impala::DataStreamSender	virtual
profile()	impala::DataStreamSender	inlinevirtual
profile_	impala::DataStreamSender	private
random_	impala::DataStreamSender	private
row_desc_	impala::DataStreamSender	private
Send(RuntimeState *state, RowBatch *batch, bool eos)	impala::DataStreamSender	virtual
sender_id_	impala::DataStreamSender	private
serialize_batch_timer_	impala::DataStreamSender	private
SerializeBatch(RowBatch *src, TRowBatch *dest, int num_receivers=1)	impala::DataStreamSender
state_	impala::DataStreamSender	private
thrift_batch1_	impala::DataStreamSender	private
thrift_batch2_	impala::DataStreamSender	private
thrift_transmit_timer_	impala::DataStreamSender	private
uncompressed_bytes_counter_	impala::DataStreamSender	private
~DataSink()	impala::DataSink	inlinevirtual
~DataStreamSender()	impala::DataStreamSender	virtual