[ https://issues.apache.org/jira/browse/APEXCORE-360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Pramod Immaneni updated APEXCORE-360: ------------------------------------- Fix Version/s: 3.5.0 > Add capability in the engine to let the operator know about the next > checkpoint window > -------------------------------------------------------------------------------------- > > Key: APEXCORE-360 > URL: https://issues.apache.org/jira/browse/APEXCORE-360 > Project: Apache Apex Core > Issue Type: Improvement > Reporter: Pramod Immaneni > Assignee: Pramod Immaneni > Fix For: 3.5.0 > > > Carryover from the older JIRA system.. > The operator should be able to call an engine API to find out the number of > windows till the next checkpoint. > Implementation of iteration feature requires the need to know the number of > windows from checkpoint. If the delay is 1 the delay operator needs to know > about the window before checkpoint by beginWindow of that window so it can > save the tuples in that window for replay in case of recovery in future. If > the delay is 2 then it needs to know 2 windows before checkpoint. > The idea is to compute the windows from checkpoint and make it available in > OperatorContext, for example by a method getWindowsFromCheckpoint. The > operator can check the windows from checkpoint in beginWindow. In the > iteration case it can save the tuples accordingly. -- This message was sent by Atlassian JIRA (v6.3.15#6346)