Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/605#issuecomment-93984865
I think this is nice work.
It would be easier to add and maintain this, if it were not hardwired into
the core flink classes, but if we could make this like a library. This would be
a good example for the `flink-contrib` project.
The changes for this should be rather small: It would boil down to not
adding the specialized methods for the `OperatorStatistics` to the
RuntimeEnvironment and the `JobExecutionResult`, but to add a util class that
converts an operator statistics accumulator into the OperatorStatistics object.
I general, I am a bit more comfortable with adding stuff as libraries than
to the core API. A lot of requests and features are coming in, if we all add
them to the core API, it will easily become unmaintainable. Staging something
first as a library is pretty uncritical. We can always add it to the API later,
if it becomes stable and heavily used.
---
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 infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
