|
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 |