[ https://issues.apache.org/jira/browse/APEXCORE-247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Pramod Immaneni closed APEXCORE-247. ------------------------------------ > Implement DefaultDelayOperator > ------------------------------ > > Key: APEXCORE-247 > URL: https://issues.apache.org/jira/browse/APEXCORE-247 > Project: Apache Apex Core > Issue Type: Sub-task > Reporter: David Yan > > This class should extend SimpleDelayOperator. It writes the tuples in the > window before each checkpoint to a DFS-backed WAL, and it overrides > firstWindow() to read from the WAL and emits the tuples at recovery. > Thomas has suggested leveraging IdempotentStorageManager in Malhar for the > WAL implementation. -- This message was sent by Atlassian JIRA (v6.3.15#6346)