http://deprecated-apache-flink-mailing-list-archive.368.s1.nabble.com/jira-Resolved-FLINK-731-Provide-a-way-to-parametrize-aggregators-and-convergence-criteria-tp219.html
Stephan Ewen resolved FLINK-731.
This was a contribution from Vasia Kalavri. The merge/rebase screwed up the commit author.
> Provide a way to parametrize aggregators and convergence criteria
> -----------------------------------------------------------------
>
> Key: FLINK-731
> URL:
https://issues.apache.org/jira/browse/FLINK-731> Project: Flink
> Issue Type: Bug
> Reporter: GitHub Import
> Assignee: Stephan Ewen
> Labels: github-import
> Fix For: 0.6-incubating
>
>
> Currently, there is no way to pass parameters to an aggregator or a convergence criterion. @StephanEwen has suggested to add support for this by changing the code for aggregators and convergence criterion to take an object, rather than a class, i.e. instead of
> `iteration.registerAggregator("my aggregator", Customaggregator.class)`
> do something like this:
> `iteration.registerAggregator("my aggregator", new CustomAggregator(params));`
> I can start working on this, but I have a question: What should the type of `params` be?
> ---------------- Imported from GitHub ----------------
> Url:
https://github.com/stratosphere/stratosphere/issues/731> Created by: [vasia|
https://github.com/vasia]
> Labels:
> Created at: Mon Apr 28 16:26:56 CEST 2014
> State: open