reef-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Dhruv Mahajan (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (REEF-1404) IMRU task state Maintenance and Preservation in Evaluator for fault tolerant
Date Mon, 29 Aug 2016 23:50:21 GMT

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

Dhruv Mahajan commented on REEF-1404:
-------------------------------------

[~markus.weimer]. How about something like this as user facing interface. It is assumed that
user adds {{IStreamingCodec<T>}} as part of task configuration.

{code}
    /// <summary>
    /// State Maneger interface visible to the user.
    /// </summary>
    /// <typeparam name="T">Type of state object.</typeparam>
    public interface IStateManager<T>
    {
        /// <summary>
        /// Adds state object to the manager for a given iteration. Only one object 
        /// can be set per iteration. The old one will be replaced if called again with 
        /// the same iteration number.
        /// </summary>
        /// <param name="iteration">Iteration number in IMRU</param>
        /// <param name="stateObject">State value</param>
        void AddState(int iteration, T stateObject);

        /// <summary>
        /// Remove the state logged at iteration.
        /// </summary>
        /// <param name="iteration">Iteration for which state should be removed.</param>
        void RemoveState(int iteration);

        /// <summary>
        /// Gets state at particular iteration. 
        /// </summary>
        /// <param name="iteration">Iteration number</param>
        /// <returns>The latest state.</returns>
        T GetState(int iteration);

        /// <summary>
        /// Gets the latest state as well as iteration number.
        /// </summary>
        /// <param name="iteration">Last iteration number</param>
        /// <returns>The latest state.</returns>
        T GetLatestState(out int iteration);
    }
{code}

> IMRU task state Maintenance and Preservation in Evaluator for fault tolerant
> ----------------------------------------------------------------------------
>
>                 Key: REEF-1404
>                 URL: https://issues.apache.org/jira/browse/REEF-1404
>             Project: REEF
>          Issue Type: Task
>            Reporter: Julia
>              Labels: FT
>
> IMRU task should be able to 
> * Maintenance and preservation the state
> * When restart, able to recover from the previous sate



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message