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

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

AddData(const TUniqueId &fragment_instance_id, PlanNodeId dest_node_id, const TRowBatch &thrift_batch, int sender_id)impala::DataStreamMgr
Cancel(const TUniqueId &fragment_instance_id)impala::DataStreamMgr
CloseSender(const TUniqueId &fragment_instance_id, PlanNodeId dest_node_id, int sender_id)impala::DataStreamMgr
CreateRecvr(RuntimeState *state, const RowDescriptor &row_desc, const TUniqueId &fragment_instance_id, PlanNodeId dest_node_id, int num_senders, int buffer_size, RuntimeProfile *profile, bool is_merging)impala::DataStreamMgr
DataStreamMgr()impala::DataStreamMgrinline
DataStreamRecvr classimpala::DataStreamMgrfriend
DeregisterRecvr(const TUniqueId &fragment_instance_id, PlanNodeId node_id)impala::DataStreamMgrprivate
FindRecvr(const TUniqueId &fragment_instance_id, PlanNodeId node_id, bool acquire_lock=true)impala::DataStreamMgrprivate
fragment_stream_set_impala::DataStreamMgrprivate
FragmentStreamSet typedefimpala::DataStreamMgrprivate
GetHashValue(const TUniqueId &fragment_instance_id, PlanNodeId node_id)impala::DataStreamMgrinlineprivate
lock_impala::DataStreamMgrprivate
receiver_map_impala::DataStreamMgrprivate
StreamMap typedefimpala::DataStreamMgrprivate