Github user tammymendt commented on the pull request:
https://github.com/apache/flink/pull/605#issuecomment-94401122
Hey, thanks for the quick feedback. I agree with separating the
contribution as a library, however I have a question. The reason I have used a
specialized method in the RuntimeEnvironment, is that for the
OperatorStatsAccumulator, we do not want to only track the accumulated
statistics per job, but also keep an array of the statistics collected at each
task. The subtaskIndex which part of the RuntimeEnvironment is passed as a
parameter to the constructor of the accumulator so that we can track which
subtask is associated to which stats. Any ideas as to how I could use the same
accumulator infrastructure but be able to associate an accumulated value with a
given subtask?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
