SpillingStats are meaningful only within the context of a stage. We should remove the local SpillingStats instance and pass a reference of SpillingStats to the spill method of RecordIdDeduplicator. This will allow RecordIdDeduplicator to update the instance of SpillingStats of the stage that uses it.
[CLASSIC] Add SpillingStats argument to spill method of RecordIdDeduplicator
- Assignee:
-
Foteini Alvanaki
- Reporter:
-
Foteini Alvanaki
- Votes:
-
0 Vote for this issue - Watchers:
-
2 Start watching this issue
- Created:
- Updated: