Impala
Impalaistheopensource,nativeanalyticdatabaseforApacheHadoop.
|
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::DataStreamMgr | inline |
DataStreamRecvr class | impala::DataStreamMgr | friend |
DeregisterRecvr(const TUniqueId &fragment_instance_id, PlanNodeId node_id) | impala::DataStreamMgr | private |
FindRecvr(const TUniqueId &fragment_instance_id, PlanNodeId node_id, bool acquire_lock=true) | impala::DataStreamMgr | private |
fragment_stream_set_ | impala::DataStreamMgr | private |
FragmentStreamSet typedef | impala::DataStreamMgr | private |
GetHashValue(const TUniqueId &fragment_instance_id, PlanNodeId node_id) | impala::DataStreamMgr | inlineprivate |
lock_ | impala::DataStreamMgr | private |
receiver_map_ | impala::DataStreamMgr | private |
StreamMap typedef | impala::DataStreamMgr | private |