[
https://issues.apache.org/jira/browse/FLINK-731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Stephan Ewen resolved FLINK-731.
--------------------------------
Resolution: Fixed
Fix Version/s: (was: pre-apache)
0.6-incubating
Assignee: Stephan Ewen
Merged in 08f189ad37a64b094ba86def8544687419c131ce
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
--
This message was sent by Atlassian JIRA
(v6.2#6252)
Locked
