Detailed Description
template<typename ValueType, typename Comparator, size_t kNumInputs>
class thrill::api::MergeNode< ValueType, Comparator, kNumInputs >::Stats
Stats holds timers for measuring merge performance, that supports accumulating the output and printing it to the standard out stream.
Collaboration diagram for MergeNode< ValueType, Comparator, kNumInputs >::Stats:Public Member Functions | |
| void | Print (Context &ctx) |
| void | PrintToSQLPlotTool (const std::string &label, size_t p, size_t value) |
Public Attributes | |
| StatsTimer | balancing_timer_ |
| A Timer accumulating all time spent while re-balancing the data. More... | |
| StatsTimer | comm_timer_ |
| A Timer accumulating all time spent communicating. More... | |
| StatsTimer | file_op_timer_ |
| A Timer accumulating all time spent in File operations. More... | |
| size_t | iterations_ = 0 |
| The count of search iterations needed for balancing. More... | |
| StatsTimer | merge_timer_ |
| A Timer accumulating all time spent while actually merging. More... | |
| StatsTimer | pivot_selection_timer_ |
| size_t | result_size_ = 0 |
| The count of all elements processed on this host. More... | |
| StatsTimer | scatter_timer_ |
| StatsTimer | search_step_timer_ |
| A Timer accumulating all time spent in global search steps. More... | |
Member Function Documentation
◆ Print()
|
inline |
Definition at line 275 of file merge.hpp.
References FlowControlChannel::AllReduce(), Context::my_rank(), Context::net, and Context::num_workers().
Referenced by MergeNode< ValueType, Comparator, kNumInputs >::PushData().
◆ PrintToSQLPlotTool()
|
inline |
Member Data Documentation
◆ balancing_timer_
| StatsTimer balancing_timer_ |
A Timer accumulating all time spent while re-balancing the data.
Definition at line 252 of file merge.hpp.
Referenced by MergeNode< ValueType, Comparator, kNumInputs >::MainOp().
◆ comm_timer_
| StatsTimer comm_timer_ |
A Timer accumulating all time spent communicating.
Definition at line 259 of file merge.hpp.
Referenced by MergeNode< ValueType, Comparator, kNumInputs >::GetGlobalRanks(), MergeNode< ValueType, Comparator, kNumInputs >::MainOp(), and MergeNode< ValueType, Comparator, kNumInputs >::SelectPivots().
◆ file_op_timer_
| StatsTimer file_op_timer_ |
A Timer accumulating all time spent in File operations.
Definition at line 248 of file merge.hpp.
Referenced by MergeNode< ValueType, Comparator, kNumInputs >::GetGlobalRanks(), and MergeNode< ValueType, Comparator, kNumInputs >::SelectPivots().
◆ iterations_
| size_t iterations_ = 0 |
The count of search iterations needed for balancing.
Definition at line 266 of file merge.hpp.
Referenced by MergeNode< ValueType, Comparator, kNumInputs >::MainOp().
◆ merge_timer_
| StatsTimer merge_timer_ |
A Timer accumulating all time spent while actually merging.
Definition at line 250 of file merge.hpp.
Referenced by MergeNode< ValueType, Comparator, kNumInputs >::PushData().
◆ pivot_selection_timer_
| StatsTimer pivot_selection_timer_ |
A Timer accumulating all time spent for selecting the global pivot elements.
Definition at line 255 of file merge.hpp.
Referenced by MergeNode< ValueType, Comparator, kNumInputs >::MainOp().
◆ result_size_
| size_t result_size_ = 0 |
The count of all elements processed on this host.
Definition at line 264 of file merge.hpp.
Referenced by MergeNode< ValueType, Comparator, kNumInputs >::PushData().
◆ scatter_timer_
| StatsTimer scatter_timer_ |
A Timer accumulating all time spent calling the scatter method of the data subsystem.
Definition at line 262 of file merge.hpp.
Referenced by MergeNode< ValueType, Comparator, kNumInputs >::MainOp().
◆ search_step_timer_
| StatsTimer search_step_timer_ |
A Timer accumulating all time spent in global search steps.
Definition at line 257 of file merge.hpp.
Referenced by MergeNode< ValueType, Comparator, kNumInputs >::MainOp().
The documentation for this class was generated from the following file:
- thrill/api/merge.hpp
