Mailing-List: contact dev-help@hama.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@hama.apache.org
Date: Mon, 30 Sep 2013 09:22:23 +0000 (UTC)
From: "Ilias Kapouranis (JIRA)" <jira@apache.org>
To: dev@hama.apache.org
Message-ID: <JIRA.12671269.1380472139551.3397.1380532943866@arcas>
In-Reply-To: <JIRA.12671269.1380472139551@arcas>
References: <JIRA.12671269.1380472139551@arcas>
Subject: [jira] [Commented] (HAMA-807) Make aggregators skip supersteps
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit


    [ https://issues.apache.org/jira/browse/HAMA-807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13781698#comment-13781698 ] 

Ilias Kapouranis commented on HAMA-807:
---------------------------------------

I don't think it would be much of an issue. 
- We have the List where we keep all the aggregators. 
- When executeAggregator(int aggrIndex) is called, we move the aggrIndex to a new List (say tempList) which keeps a pair (aggrIndex,aggrClass). 
- At the end of the superstep, if tempList is empty then all the aggregators will be executed, else only those which are in it.
- When all aggregators have finished, we move the pairs from tempList to the main List and we put the aggregators to their previous indexes.

Hope this helps.

> Make aggregators skip supersteps
> --------------------------------
>
>                 Key: HAMA-807
>                 URL: https://issues.apache.org/jira/browse/HAMA-807
>             Project: Hama
>          Issue Type: New Feature
>          Components: graph
>    Affects Versions: 0.6.2
>            Reporter: Anastasis Andronidis
>            Assignee: Anastasis Andronidis
>            Priority: Minor
>              Labels: aggregator, features, graph
>             Fix For: 0.6.3
>
>
> Users should be able to control their aggregators better by making aggregators to skip calculations in specific supersteps.
> This functionality can be accessed by the method:
> skipSuperstepForAggrigator(int aggrIndex);


--
This message was sent by Atlassian JIRA
(v6.1#6144)