auto& trans_stats = get_by_src(w_stats.stats_by_src, t.get_src());
++(trans_stats.num_records);
trans_stats.data_bytes += ex->get_length();
- w_stats.record_group_data_bytes += ex->get_length();
+ w_stats.data_bytes += ex->get_length();
}
return trans_intr::make_interruptible(
rbm->write(paddr + offset,
),
sm::make_counter(
"record_group_data_bytes",
- stats.record_group_data_bytes,
+ stats.data_bytes,
sm::description("bytes of data when write record groups"),
label_instances
),
stats.record_group_padding_bytes +=
(rg.size.get_mdlength() - rg.size.get_raw_mdlength());
stats.record_group_metadata_bytes += rg.size.get_raw_mdlength();
- stats.record_group_data_bytes += rg.size.dlength;
+ stats.data_bytes += rg.size.dlength;
stats.record_batch_stats.increment(rg.get_size());
for (const record_t& r : rg.records) {
<< ",sizeB="
<< fmt::format(dfmt, p.stats.get_total_bytes()/d_num_io)
<< "("
- << fmt::format(dfmt, p.stats.record_group_data_bytes/d_num_io)
+ << fmt::format(dfmt, p.stats.data_bytes/d_num_io)
<< ","
<< fmt::format(dfmt, p.stats.record_group_metadata_bytes/d_num_io)
<< ","
grouped_io_stats io_depth_stats;
uint64_t record_group_padding_bytes = 0;
uint64_t record_group_metadata_bytes = 0;
- uint64_t record_group_data_bytes = 0;
+ uint64_t data_bytes = 0;
counter_by_src_t<trans_writer_stats_t> stats_by_src;
bool is_empty() const {
uint64_t get_total_bytes() const {
return record_group_padding_bytes +
record_group_metadata_bytes +
- record_group_data_bytes;
+ data_bytes;
}
void add(const writer_stats_t &o) {
io_depth_stats.add(o.io_depth_stats);
record_group_padding_bytes += o.record_group_padding_bytes;
record_group_metadata_bytes += o.record_group_metadata_bytes;
- record_group_data_bytes += o.record_group_data_bytes;
+ data_bytes += o.data_bytes;
add_srcs(stats_by_src, o.stats_by_src);
}
io_depth_stats.minus(o.io_depth_stats);
record_group_padding_bytes -= o.record_group_padding_bytes;
record_group_metadata_bytes -= o.record_group_metadata_bytes;
- record_group_data_bytes -= o.record_group_data_bytes;
+ data_bytes -= o.data_bytes;
minus_srcs(stats_by_src, o.stats_by_src);
}
};