Github user uce commented on the pull request:
https://github.com/apache/incubator-flink/pull/210#issuecomment-63456473
Very cool! I think this is a great addition and we will improve on the
performance soon :)
@zentol, as @StephanEwen said it makes sense to execute right away. You can
think of this as "actions" from Spark, which get results back to the user. He
can't use a map function, because he doesn't emit any records, but just adds
them to the accumulator.
I've tried this out locally and it works, but you have to add the random
IDs as you run into problem with multiple actions in the same program otherwise.
With this change, we also should allow to have prorams **without** sinks.
Currently, you get a warning if you only have "actions" like collect/count
without a sink.
Before we can merge this, you should also add test cases for both operators
and make sure that it works with multiple actions per program.
---
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.
---
