-
Type:
Task
-
Resolution: Fixed
-
Priority:
Major - P3
-
Affects Version/s: None
-
Component/s: None
-
None
-
Atlas Streams
-
Fully Compatible
-
None
-
3
-
None
-
None
-
None
-
None
-
None
-
None
To retain lifetime per-target input/output counts for a stream processor, we will save this information in checkpoint. We already save operator stats in checkpoints, so this will just build on that.
- Modify the OperatorStatsDoc IDL struct to contain fields for the new fields in the in-memory OperatorStats struct. We can use array<PerTargetStatsDoc>
- When then need to modify the utility methods toOperatorStatsDoc and to OperatorStats to save and restore per target states
- Make sure to add tests using commonTest!
- Enable the feature flag, put things under isInternal