Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

dbsp: Summarize operator metadata into root in circuit profiles. #2553

Merged
merged 1 commit into from
Sep 23, 2024

Conversation

blp
Copy link
Member

@blp blp commented Sep 22, 2024

With this, the root node in circuit profiles includes additional information that summarizes all the operators in the circuit, like this:

total size: 14385360
allocated bytes: 4.75 GiB
used bytes: 4.75 GiB
allocations: 34030654
shared bytes: 4.75 GiB
batches: 210
storage size: 3.53 GiB
merging batches: 20
merging size: 2.18 GiB
merge reduction: 23.93%
output redundancy: 0.00%

With this, the root node in circuit profiles includes additional
information that summarizes all the operators in the circuit, like this:

```
total size: 14385360
allocated bytes: 4.75 GiB
used bytes: 4.75 GiB
allocations: 34030654
shared bytes: 4.75 GiB
batches: 210
storage size: 3.53 GiB
merging batches: 20
merging size: 2.18 GiB
merge reduction: 23.93%
output redundancy: 0.00%
```

Signed-off-by: Ben Pfaff <blp@feldera.com>
@blp blp added enhancement DBSP core Related to the core DBSP library performance labels Sep 22, 2024
@blp blp requested a review from ryzhyk September 22, 2024 17:52
@blp blp self-assigned this Sep 22, 2024
@@ -174,6 +174,14 @@ impl WorkerProfile {
pub fn total_shared_bytes(&self) -> Result<HumanBytes, MetaItem> {
self.attribute_total_as_bytes(SHARED_BYTES_LABEL)
}

pub fn merge(&mut self, other: &Self) {
for (id, dst) in self.metadata.iter_mut() {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

It probably doesn't happen now, but if other has a different set of metrics, some of them can get lost

@blp blp added this pull request to the merge queue Sep 23, 2024
Merged via the queue into main with commit 4deece2 Sep 23, 2024
5 of 7 checks passed
@blp blp deleted the profile-summary branch September 23, 2024 22:44
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
DBSP core Related to the core DBSP library performance
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants