apex-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ilooner <...@git.apache.org>
Subject [GitHub] apex-malhar pull request #322: APEXMALHAR-2063 Made window data manager use ...
Date Sun, 24 Jul 2016 20:36:12 GMT
Github user ilooner commented on a diff in the pull request:

    https://github.com/apache/apex-malhar/pull/322#discussion_r71995041
  
    --- Diff: library/src/main/java/org/apache/apex/malhar/lib/wal/WindowDataManager.java
---
    @@ -41,15 +41,42 @@
      *
      * @since 2.0.0
      */
    -public interface WindowDataManager extends StorageAgent, Component<Context.OperatorContext>
    +public interface WindowDataManager extends Component<Context.OperatorContext>
     {
       /**
    +   * Save the state for a window id.
    +   * @param object    state
    +   * @param windowId  window id
    +   * @throws IOException
    +   */
    +  void save(Object object, long windowId) throws IOException;
    +
    +  /**
    +   * Gets the object saved for the provided window id. <br/>
    +   * Typically it is used to replay tuples of successive windows in input operators after
failure.
    +   *
    +   * @param windowId window id
    +   * @return saved state for the window id.
    +   * @throws IOException
    +   */
    +  Object retrieve(long windowId) throws IOException;
    +
    +  /**
    +   * Delete the artifact corresponding to the
    --- End diff --
    
    complete javadoc here?


---
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 infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

Mime
View raw message