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 [email protected] or file a JIRA ticket
with INFRA.
---
